【flink报错】flink cdc无主键时的操作

文章目录一. 报错二. 解决一. 报错“org.apache.flink.table.api.validationexception: ‘scan.incremental.snapshot.chunk.key-column’ must be set when the table doesn’t have primary keys”报错提示当表没有主键时必须设置 ‘scan.incremental.snapshot.chunk.key-column’。这里表没有主键不是flink table中设置的primary key而是物理表中没有主键。二. 解决如上述报错提示在创建表的时候为没有主键的表指定一个唯一的标识列作为’scan.incremental.snapshot.chunk.key-column’。如下为MY_TABLE表指定了id列作为’scan.incremental.snapshot.chunk.key-column’。这样就可以解决没有主键的表无法进行增量捕获的问题。CREATETABLEIFNOTEXISTSmy_table(idBIGINT,name STRING,ageINT,PRIMARYKEY(id)NOTENFORCED)WITH(connectormysql-cdc,hostnamexxx,port1521,usernameconn_uat,passwordxxxx,database-nameCONN_UAT,schema-namestrc,table-nameMY_TABLE,scan.incremental.snapshot.chunk.key-columnid);