【Flink 实战系列】Incremental snapshot for tables requires primary key, but table test.ab doesn’t have pri_org.apache.flink.util.flinkexception: global failu

【Flink 实战系列】Incremental snapshot for tables requires primary key, but table test.ab doesn’t have primary key

问题背景

今天有同学问了这么一个问题，在使用 Flink CDC 同步数据到 Hudi 时，任务抛出异常，完整的报错信息如下所示：

org.apache.flink.util.FlinkException: Global failure triggered by OperatorCoordinator for 'Source: mysql_cdc[5]' (operator 1fcd650af251e8033f91cba4d16ab1ec).
	at org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder$LazyInitializedCoordinatorContext.failJob(OperatorCoordinatorHolder.java:556)
	at org.apache.flink.runtime.operators.coordination.RecreateOnResetOperatorCoordinator$QuiesceableContext.failJob(RecreateOnResetOperatorCoordinator.java:231)
	at org.apache.flink.runtime.source.coordinator.SourceCoordinatorContext.failJob(SourceCoordinatorContext.java:316)
	at o
1
2
3
4