Flink---WaterMark机制

背景  使用Event time时间模型时，因为网络或传输等缘由，事件被Flink处理的顺序不必定是事件产生的顺序（乱序），可能会存在两方面影响：html 当前窗口不知道什么时候中止，开始计算结果； 影响窗口计算结果的准确性，见示例； WaterMark机制  WaterMark本质上是一个带有时间戳的特殊event，当Flink中的运算符接收到水印时，它明白（假设）它不会看到比该时间戳更早的消息

>>阅读原文<<