FlinkSQL中的Watermark是如何工作的？

　　1、时间概念： Flink区分事件时间（Event Time）和处理时间（Processing Time）。Watermark基于事件时间，表示在此时间点之前的事件都已经到达。

　　2、生成与传递： Watermark通过Source Function生成，并随着事件流传递到下游算子。每个算子根据接收到的Watermark更新其内部时间状态。

　　3、窗口触发： Watermark到达窗口的结束时间时，触发窗口的计算和关闭。这确保了即使有数据延迟到达，窗口计算也能够正确处理。

　　4、处理延迟数据： 通过Watermark，Flink能够处理迟到数据。数据如果在Watermark之后到达，但仍在允许的延迟范围内，可以被窗口正确处理。

很赞哦！

python编程网提示：转载请注明来源www.python66.com。
有宝贵意见可添加站长微信(底部)，获取技术资料请到公众号(底部)。同行交流请加群