Re:回复：Flink mysqlCDC ,然后jdbc sink 到mysql 乱序问题

Sun, 25 Oct 2020 20:37:09 -0700 

就是一个update 操作。就是乱序了 。
在 2020-10-23 19:12:20，"熊云昆" <[email protected]> 写道：
>你的数据有没有时间属性？可以用时间来判断吧
>
>
>| |
>熊云昆
>|
>|
>邮箱：[email protected]
>|
>
>签名由 网易邮箱大师 定制
>
>在2020年10月23日 14:21，air23 写道：
>你好，
>这边发现使用cdc读取mysql ，然后写入mysql会有乱序问题
>在上游mysql update一条数据，connert=print是有一条delete 和一条insert的数据，
>但是jdbc写入mysql时候 发现mysql有时候是正常的，但是有时候会没有，当把并行度改成1的时候是正常的。
>这边怀疑是乱序了，先insert 再delete了。所以导致结果表 没有这条数据，请问flink sql 或者flink cdc 怎么保证有序。

回复