tongchenkeji 发表于:2022-10-24 23:20:570次点击 已关注取消关注 关注 私信 我通过Flink SQL 去读取kudu的数据报的这个错误可以给些建议嘛?[阿里云实时计算 Flink版] 暂停朗读为您朗读 「点点赞赏,手留余香」 赞赏 还没有人赞赏,快来当第一个赞赏的人吧! 海报 实时计算Flink版# SQL1285# 实时计算 Flink版3179# 流计算2236
三掌柜666AM 2023-11-27 18:13:04 1 楼主你好,看了你的报错信息,你可以排查一下对应的报错位置,报错信息提示的是找不到合适的table factory,查询报错类TableFactoryService.scala 源码182行(报错信息中报错位置) 遇到这个问题,debug进去,看下到底那个属性对应不上,然后针对解决。
认真学习的heartAM 2023-11-27 18:13:04 2 我建议题主可以试试看: 1.检查Kudu表是否存在,并确保Flink有权访问Kudu表。 2.检查Flink SQL语句是否正确,确保表名和字段名正确。 3.检查Flink是否已经正确配置Kudu连接,确保Kudu连接参数正确。 4.检查Flink是否已经正确安装Kudu Connector,确保Kudu Connector版本与Flink版本兼容。
楼主你好,看了你的报错信息,你可以排查一下对应的报错位置,报错信息提示的是找不到合适的table factory,查询报错类TableFactoryService.scala 源码182行(报错信息中报错位置) 遇到这个问题,debug进去,看下到底那个属性对应不上,然后针对解决。
我建议题主可以试试看: 1.检查Kudu表是否存在,并确保Flink有权访问Kudu表。 2.检查Flink SQL语句是否正确,确保表名和字段名正确。 3.检查Flink是否已经正确配置Kudu连接,确保Kudu连接参数正确。 4.检查Flink是否已经正确安装Kudu Connector,确保Kudu Connector版本与Flink版本兼容。