Flink中的Event Time和Watermarks如何处理迟到数据？

　　1、水印策略： 水印（Watermarks）标识了在特定时间之前的所有数据都已经到达，用于处理乱序事件。

　　2、迟到数据处理： 可以定义允许的迟到时间，对于迟到的数据执行更新或迟到处理逻辑。

　　3、窗口更新： 对于已经触发的窗口，如果迟到数据到达，可以重新计算并更新结果。

很赞哦！

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