开发者社区> 问答> 正文

About the windowOperator and Watermark

Hi Experts,

Given that a window in the stream is configured with short window size like timeWinodw(3s), and I gotta utilize Event time and Periodic Watermark. The stream input is [watermark(7) | 6, 5, 3, 4, 1, 2], and then two windows are created (3,1,2) (6,5,4) before watermark(7) arriving. But in this situation when the current watermark is received, which window or how many windows will be be triggered to fire and emit? My question is what will the windowOperater do when it comes to two parellel windows edge end timestamps both smaller than cerrent watermark timestamps?*来自志愿者整理的flink邮件归档

展开
收起
EXCEED 2021-12-02 11:15:29 903 0
1 条回答
写回答
取消 提交回答
  • When a Watermark arrives the window operator will emit all windows that are considered finished at the time of the Watermark. In your example (assuming both windows are finished) they will both be emitted.

    *来自志愿者整理的FLINK邮件归档

    2021-12-02 11:26:38
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Window_Time_Watermark 立即下载
低代码开发师(初级)实战教程 立即下载
阿里巴巴DevOps 最佳实践手册 立即下载