1. Toy模板网首页
  2. > Toy博客

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

10月前 作者：JasonLee实时计算 分类：Toy博客 阅读(45) 违法举报

这篇具有很好参考价值的文章主要介绍了【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 时，任务抛出异常，完整的报错信息如下所示：文章来源地址https://www.toymoban.com/news/detail-403428.html

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的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处： 如若内容造成侵权/违法违规/事实不符，请点击违法举报进行投诉反馈，一经查实，立即删除！

分享到：
领支付宝红包 赞助服务器费用

相关文章

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包，优惠每天领

二维码1

领取红包

二维码2

领红包