网站介绍:文章浏览阅读391次。6.4 窗口允许迟到的数据(1)迟到数据概念迟到数据:时间戳 小于 watermark的数据(2)窗口允许迟到1) 当 wm >= 窗口最大时间戳时, 会 触发,但是不会关窗2) 当 窗口最大时间戳 + 允许迟到时间 >= wm >= 窗口最大时间戳, 每来一条迟到数据,都会进入窗口,触发3) 当 wm >= 窗口最大时间戳 + 允许迟到时间 , 会关窗, 迟到数据不再进入窗口,不会再触发(3)代码无序流watersensor、乱序程度=3、滚动事件窗口大小10_flink 指定允许再次迟到的时间
- 链接地址:https://blog.csdn.net/qq_43523503/article/details/114958723
- 链接标题:Flink窗口迟到机制_flink 指定允许再次迟到的时间-CSDN博客
- 所属网站:blog.csdn.net
- 被收藏次数:3845
- 网站标签:flink 指定允许再次迟到的时间