[In A Word]In A Word章9　Flink 的WaterMark

watermark是一种衡量Event Time进展的机制，它是数据本身的一个隐藏属性。通常基于Event Time的数据，自身都包含一个timestamp.watermark是用于处理乱序事件的，而正确的处理乱序事件，通常用watermark机制结合window来实现

window的触发要符合以下几个条件：

1. watermark时间 >= window_end_time
2. 在[window_start_time,window_end_time)中有数据存在

同时满足了以上2个条件，window才会触发。

watermark是一个全局的值，不是某一个key下的值，所以即使不是同一个key的数据，其warmark也会增加.

[In A Word]In A Word章9　Flink 的WaterMark

原文：https://www.cnblogs.com/szss/p/11464845.html