开发者社区> 问答> 正文

窗口触发机制的疑惑

窗口触发的条件是: 1、watermark时间 >= window_end_time 2、在[window_start_time,window_end_time)中有数据存在

但是在代码中我们可以看到如果 if (window.maxTimestamp() <= ctx.getCurrentWatermark()) { // if the watermark is already past the window fire immediately return TriggerResult.FIRE; } else { ctx.registerEventTimeTimer(window.maxTimestamp()); return TriggerResult.CONTINUE; } 是不是可以这么理解。如果watermark一直比window 的end_Time-1 小,那么到了窗口的endTime-1 ,窗口就会自动被触发 非常感谢大牛们的解答*来自志愿者整理的flink邮件归档

展开
收起
毛毛虫雨 2021-12-07 14:08:13 488 0
1 条回答
写回答
取消 提交回答
  • 是的。*来自志愿者整理的flink

    2021-12-07 15:24:19
    赞同 展开评论 打赏
问答地址:
问答排行榜
最热
最新

相关电子书

更多
fibjs 模块重构从回调到协程--陈垒 立即下载
fibjs 模块重构从回调到协程 立即下载
动态、高效,蚂蚁动态卡片的内核逻辑 立即下载