admin管理员组

文章数量:1794759

Flink Recovery is suppressed by NoRestartBackoffTime Strategy

Flink Recovery is suppressed by NoRestartBackoffTime Strategy

Recovery is suppressed by NoRestartBackoffTime Strategy 主键冲突 1、错误场景

首先我这个错误场景是使用Flink连接mysql时报的错。

2、错误原因

导致这个报错的原因是因为，mysql表里面设置了主键，并且新插入的数据中在mysql中已经存在，所以才会导致主键冲突。

3、解决方案 方案一：

第一种解决方案，就是在flink DDL中添加主键：primary key(id) NOT ENFORCED 不过flink 会将已经存在结果表的数据给更新掉（只会更新重复的key_id部分）。

方案二：

如果不想将历史数据updata掉，可以在mysql中设置自增ID。 不过这种方式会导致结果表中有重复数据，因为他是直接将数据追加进来的。

以上纯属个人观点，如果有什么错误信，欢迎大家指正！！！

本文标签： recoveryFlinksuppressedstrategyNoRestartBackoffTime

版权声明：本文标题：Flink Recovery is suppressed by NoRestartBackoffTime Strategy 内容由林淑君副主任自发贡献，该文观点仅代表作者本人， 转载请联系作者并注明出处：http://www.xiehuijuan.com/baike/1686592325a85390.html， 本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容，一经查实，本站将立刻删除。