入口： [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，会不会导致乱序？最终丢数据？？*
