Flink Streaming中Global Window(全局窗口)的起始时间是何时?
Flink Global Window 起始时间问题解答
我们可以直接结合Flink的窗口设计逻辑给出明确结论:
- 网传「窗口起始时间从1970年1月1日00:00:00(Unix纪元起始时间)开始」的规则,仅适用于时间驱动的常规窗口,包括滚动时间窗口、滑动时间窗口、会话窗口。这类窗口的时间边界会基于窗口大小从Unix纪元开始对齐计算,和Flink作业启动时间、第一个事件到达时间没有任何关联。
GlobalWindow是特殊的窗口类型,本身没有预设的固定时间边界:所有分配到同一个Key的元素,都会被放入同一个GlobalWindow实例中,默认状态下永远不会自动触发计算,必须搭配自定义触发器才能定义窗口的触发、清理逻辑,因此它本身不存在默认的起始时间设定。- 如果你看到GlobalWindow出现从「第一个事件到达时间」开始计算的效果,本质是自定义触发器的逻辑导致的,并非GlobalWindow本身的默认特性。
内容的提问来源于stack exchange,提问作者Akula
相关产品推荐
相关产品推荐

