Flink CDC里为什么我在用flinkcdc3同步mysql到doris的时候语句不同步？

flink cdc 3.0版本确实有这个问题，你那边解决了吗？

在使用 Flink CDC (Continuous Data Capture) 从 MySQL 同步数据到 Doris 时，如果 delete 语句无法同步，可能的原因有以下几点：

1. CDC Source端处理：

   • 不支持Delete事件捕获：早期版本的Flink CDC可能只支持插入（INSERT）和更新（UPDATE）事件的捕获，而不支持删除事件。但Flink CDC v2.x版本集成了Debezium等工具，理论上应该能够捕获MySQL的DELETE操作。

2. 配置问题：

   • 确保在配置Flink CDC连接MySQL作为数据源时，启用了binlog格式为ROW，并且设置正确以捕获所有DML操作（包括DELETE）。

3. Schema映射与转换：

   • 在将变更数据流转换并写入Doris之前，检查数据转换逻辑是否正确处理了DELETE事件。例如，如果只是简单地将变更事件应用到目标表，而没有实现对Doris的相应DELETE操作，那么删除事件就不会被正确反映。

4. Doris Sink端处理：

   • Doris sink connector在接收到DELETE事件后，需要能够正确地执行相应的删除操作。确认所使用的Doris sink插件或者自定义的sink逻辑是否完整实现了对DELETE事件的支持。

5. 事务和一致性保证：

   • 考虑到分布式系统的一致性问题，确保在Flink作业中的事务边界设置合理，能正确处理MySQL的删除事务。