Hi air, 保证内部是 Forword 试试,因为内部是 Hash 或者 Rebalance 的话,就会出现相同的数据的操作记录被不同的并发处理,这样到 sink 时候就会出现乱序的可能。
Best, Hailong Wang. 在 2020-10-23 13:21:19,"air23" <wangfei23_...@163.com> 写道: >你好, >这边发现使用cdc读取mysql ,然后写入mysql会有乱序问题 >在上游mysql update一条数据,connert=print是有一条delete 和一条insert的数据, >但是jdbc写入mysql时候 发现mysql有时候是正常的,但是有时候会没有,当把并行度改成1的时候是正常的。 >这边怀疑是乱序了,先insert 再delete了。所以导致结果表 没有这条数据,请问flink sql 或者flink cdc 怎么保证有序。