您好，Watermark Event 提供的 Watermark TS 字段主要用于流式计算中，为提高计算同步数据实时性提供一个功能。有一篇关于 Flink 支持 Watermark Event 的博客，可以研究一下。Flink最佳实践 - Watermark原理及实践问题解析_event time skew-CSDN博客
另外在使用实现方面，ticdc 也有一篇文档有助您了解 tiflow/docs/distributed-scheduling.md at 7e5026f844fbcaacd56df764591cb489ce53ecfb · pingcap/tiflow · GitHub