Flink这个问题怎么解决？数据库的binlog 是 先删除后新增，但是 cdc 解析到的是先新增后删除，使用的方式是，用flink sql 读取mysql binlog, 然后写入到kafka, cdc 的版本 2.2.1 2.4.2 都出现这个问题，flink 版本是 1.15。flink 的并行度调整成1 还是会偶尔出现，不是必现的。github 上也没有搜索到相关的issue。
本文来自投稿，不代表新手站长_郑州云淘科技有限公司立场，如若转载，请注明出处：http://www.cnzhanzhang.com/17638.html
![为什么没有切换至远程桌面
-[阿里云_云淘科技]](http://www.cnzhanzhang.com/wp-content/themes/justnews/themer/assets/images/lazy.png)