admin 管理员组

文章数量: 1184232

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。
不过这种方式会导致结果表中有重复数据，因为他是直接将数据追加进来的。

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

本文标签： Recovery Flink suppressed Strategy NoRestartBackoffTime

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