Hi, @air23, 你能提供下完整的sql吗？，我来复现下这个问题 ________________________________ 发件人: air23 <[email protected]> 发送时间: 2020年10月23日 6:21 收件人: [email protected] <[email protected]> 主题: Flink mysqlCDC ,然后jdbc sink 到mysql 乱序问题
你好， 这边发现使用cdc读取mysql ，然后写入mysql会有乱序问题 在上游mysql update一条数据，connert=print是有一条delete 和一条insert的数据， 但是jdbc写入mysql时候 发现mysql有时候是正常的，但是有时候会没有，当把并行度改成1的时候是正常的。 这边怀疑是乱序了，先insert 再delete了。所以导致结果表 没有这条数据，请问flink sql 或者flink cdc 怎么保证有序。
