Flink源码阅读：Watermark机制

在 Flink 中 Watermark 是用来解决数据乱序问题的，它也是窗口关闭的触发条件。对于 Watermark 的概念和用法还不熟悉的同学可以先阅读
Flink学习笔记：时间与Watermark一文。下面我们进入正题，开始梳理 Watermark 相关的源码。