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

网友收藏2024-01-22 20:34

链接地址：https://blog.csdn.net/qq_43523503/article/details/114958723
链接标题：Flink窗口迟到机制_flink 指定允许再次迟到的时间-CSDN博客
所属网站：blog.csdn.net
被收藏次数：2124

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

本文地址：https://tebull.com/detail/484923.html

标签：flink 指定允许再次迟到的时间