Flink CDC里有没有遇到这些情况,啊? 如果任务不重启, 不管是新增删除编辑都是没有问题的, 只要有一端的flink任务重启了, 就会出现以下问题: mysql同步到kafka(采集数据), 再由kafka同步kafka(搬运数据), 再由kafka同步到mysql(数据落库), 当停止采集或者落库任务后, 再次启动采集或者落库任务, 现在出现以下几个问题
现在现象: ① 源表新增数据同步同步到目标表, 可以对新增的数据进行编辑同步到目标表, 可以新增的数据进行删除, 目标也会同步删除
② 源表旧数据进行编辑, 目标表也会同步编辑的数据, 但是如果编辑后再删除源表数据, 目标表数据会还原成编辑之前的数据, 实质上源表数据已经删除了
③ 源表删除旧数据, 目标表不会同步删除
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。