大佬们，Flink CDC中我碰到一个低级错误？表更新一条语句，flink cdc翻译成一条dele
大佬们，Flink CDC中我碰到一个低级错误？Flink SQL> insert into sink_user select * from source_user;WARNING: An illegal reflective access operation has occurred WARNING: Illegal reflective access by org.apache.flink.api.java.ClosureCleaner (file:/home/iotmp/flink-1.17.1/lib/flink-dist-1.17.1.jar) to field java.lang.String.value WARNING: Please consider reporting this to the maintainers of org.apache.flink.api.java.ClosureCleaner WARNING: Use --illegal-access=warn to enable warnings of further illegal reflective access operations WARNING: All illegal access operations will be denied in a future release表更新一条语句，flink cdc翻译成一条delete和update，但是结果是目标表多一条记录，delete没有被执行？单独删除一条记录可以同步的，我用的最新1.17版本，看了下，是有2个任务，但是两个任务不同啊，这也影响？
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
-
是不是起了多个cdc任务啊，我之前遇到的是重复提交了同样的任务出现这这种现象，你这个目标表没主键吧，insert into sink_user select * from source_user; 这个不是upsert语句吧，可以查看下具体Flink的算子结构，是不是有什么DropUpdateBefore的算子存在，生成的执行图，此回答整理自钉群“Flink CDC 社区”
2023-06-04 19:44:05赞同 展开评论