1. 新手站长_郑州云淘科技有限公司首页
  2. 阿里云

Flink这个问题怎么解决？ -[阿里云_云淘科技]

匿名 • • 阿里云

Flink这个问题怎么解决？数据库的binlog 是 先删除后新增，但是 cdc 解析到的是先新增后删除，使用的方式是，用flink sql 读取mysql binlog, 然后写入到kafka, cdc 的版本 2.2.1 2.4.2 都出现这个问题，flink 版本是 1.15。flink 的并行度调整成1 还是会偶尔出现，不是必现的。github 上也没有搜索到相关的issue。

本文来自投稿，不代表新手站长_郑州云淘科技有限公司立场，如若转载，请注明出处：https://www.cnzhanzhang.com/17638.html

赞 (0)
匿名
上一篇 2023年12月28日
下一篇 2023年12月28日

相关推荐

新手站长从“心”出发，感谢16年您始终不离不弃。