Flink 实战系列Incremental snapshot for tables requires primary key, but table test.ab doesn’t have pri
Posted JasonLee实时计算
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Flink 实战系列Incremental snapshot for tables requires primary key, but table test.ab doesn’t have pri相关的知识，希望对你有一定的参考价值。
【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以上是关于Flink 实战系列Incremental snapshot for tables requires primary key, but table test.ab doesn’t have pri的主要内容，如果未能解决你的问题，请参考以下文章
Flink实战系列Flink SQL 写入 kafka 自定义分区策略
Flink实战系列Flink 读取 Hive 数据同步到 Kafka
Flink实战系列Flink 本地 Web UI 的配置及使用