【详述】FlinkTableApi,导入kafka数据,jdbc-url写集群的所有ip,不报错,数据导入不进去,只写一个ip导入成功
【导入/导出方式】flink-connector-starrocks导入
【背景】做过哪些操作?
【业务影响】
【StarRocks版本】例如:1.18.2
【集群规模】例如:2fe(1 follower+1observer)+3be(fe与be混部)
【机器信息】
【附件】
可能的原因有
- StarRocks版本过低
- 你的connector使用不正确。
建议: - 将您的StarRocks升级
- 提供下您的code check下。
- StarRocks版本写错了,是2.3.0
2.connector用starrocks
3.这样写一个就没问题,能导入到库里
写多个就不行,导入不到库里,每个单个写是没有问题的。