Flink窗口迟到机制_flink 指定允许再次迟到的时间-CSDN博客

网站介绍:文章浏览阅读391次。6.4 窗口允许迟到的数据(1)迟到数据概念迟到数据:时间戳 小于 watermark的数据(2)窗口允许迟到1) 当 wm >= 窗口最大时间戳时, 会 触发,但是不会关窗2) 当 窗口最大时间戳 + 允许迟到时间 >= wm >= 窗口最大时间戳, 每来一条迟到数据,都会进入窗口,触发3) 当 wm >= 窗口最大时间戳 + 允许迟到时间 , 会关窗, 迟到数据不再进入窗口,不会再触发(3)代码无序流watersensor、乱序程度=3、滚动事件窗口大小10_flink 指定允许再次迟到的时间