Caused by: org.apache.flink.table.api.ValidationException: ‘scan.incremental.snapshot.chunk.key-...
翻译过来就是：没有主键的源表同步时，需要设置参数 'scan.incremental.snapshot.chunk.key-column'利用 doris 官网的方式，用flink CDC 同步mysql整库数据至doris。，不同的库表列之间用。
·
Caused by: org.apache.flink.table.api.ValidationException: 'scan.incremental.snapshot.chunk.key-column' must be set when the table doesn't have primary keys.
问题背景：
利用 doris 官网的方式，用flink CDC 同步mysql整库数据至doris
flink-doris-connector-1.18-1.5.2.jar
flink 1.18
doris 2.0.1
问题分析：
翻译过来就是：没有主键的源表同步时，需要设置参数 'scan.incremental.snapshot.chunk.key-column'
解决办法：
例如：scan.incremental.snapshot.chunk.key-column=database.table:column,database.table1:column...，不同的库表列之间用,隔开。
魔乐社区（Modelers.cn) 是一个中立、公益的人工智能社区，提供人工智能工具、模型、数据的托管、展示与应用协同服务，为人工智能开发及爱好者搭建开放的学习交流平台。社区通过理事会方式运作，由全产业链共同建设、共同运营、共同享有，推动国产AI生态繁荣发展。
更多推荐
2
0- 0
已为社区贡献1条内容
所有评论(0)