Flink CDC中mysql 同步到es 日志不报错 也不会同步数据？

这个问题可能是由于以下几个原因导致的：

1. Flink CDC的工作模式是异步的，也就是说，它会在接收到数据库的日志事件后立即将其添加到DataStream中，然后立即开始处理下一条日志事件。这意味着，如果你的ES集群的压力过大，或者网络延迟过高，可能会导致Flink CDC的数据无法及时被写入ES。

2. 你可能需要调整Flink CDC和ES的配置。例如，你可以增加Flink CDC的并行度，以提高数据的处理速度；你也可以增加ES的内存，以提高其写入性能。

3. 你可能需要在Flink CDC和ES之间增加一些缓冲。例如，你可以在Flink CDC之后增加一个Buffer Operator，然后在ES之前增加一个Flush Operator。这样，Flink CDC可以将数据先写入Buffer Operator，然后再由Buffer Operator将数据写入ES。

4. 你可能需要调整Flink的调度策略。例如，你可以将Flink的运行模式设置为"always-running"，这样可以确保Flink始终处于活跃状态，不会因为任务的完成而停止。

5. 你可能需要调整ES的配置。例如，你可以增加ES的索引刷新频率，以提高索引的创建速度。

6. 你可能需要检查你的代码。例如，你可能需要检查你的DataStream是否正确地被写入ES，你的Watermark是否正确地设置，等等。