---------- Forwarded message --------- 发件人： Guo Thompson <gwqloveli...@gmail.com> Date: 2022年2月28日周一 16:39 Subject: flink-connector-jdbc sink mysql是否会存在乱序问题 To: user-zh <user-zh@flink.apache.org>
入口： [image: image.png] 批量处理： [image: image.png] 刷盘： executeBatch按理来讲就是mysql的一个事务。 [image: image.png] *疑惑：从flush中可以看到，底层是分开了两个executeBatch，举一个例子：* *kafka里面消息从flink-cdc通过debizium采集出来，对update的mysql操作会对应两条消息(op:d,op:c)，这时候如果d和c两条消息在不同的executor中，在不同的executeBatch，会不会导致乱序？最终丢数据？？*
