Caused by: org.apache.flink.table.api.ValidationException: ‘scan.incremental.snapshot.chunk.key-..._scan.incremental.snapshot.chunk.key-column' must b

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...，不同的库表列之间用,隔开。