无序时间事件窗口下Flink窗口结果差异及起始时间疑问

这是个非常典型的Flink事件时间窗口与水印、窗口对齐规则交互的问题，咱们一步步拆解清楚：

一、现象背后的核心原因 #

你的代码里有两个关键细节决定了输出差异：

1. 水印生成逻辑：你用的是AssignerWithPunctuatedWatermarks，每收到一个事件就生成一个等于该事件时间戳的水印。这意味着水印会随着事件的到来跳跃式前进，后到的事件如果时间戳比当前水印小（比如事件1比事件2晚到但时间更早），就会被判定为迟到事件。
2. 窗口触发与迟到事件处理：Flink事件时间窗口的触发条件是水印 >= 窗口结束时间，窗口触发后就会关闭，后续再来的属于该窗口的迟到事件会被默认丢弃。但如果窗口还没触发（水印没到结束时间），即使事件时间戳比当前水印小，只要它属于这个未关闭的窗口，就会被正常加入窗口。

结合事件顺序（2→1→3）和不同窗口大小的对齐规则，就能解释所有现象：

典型例子拆解 #

窗口大小3秒（3000ms）

• 窗口对齐后，三个事件分属两个窗口：
  • 事件1（1526056649167）→ 窗口[1526056647000, 1526056650000)
  • 事件2、3 → 窗口[1526056650000, 1526056653000)
• 事件处理流程：
  1. 事件2先到，水印跳到1526056650167，这个值已经超过第一个窗口的结束时间（1526056650000），所以第一个窗口触发，但里面没有事件（事件1还没来），无输出。
  2. 事件1后到，时间戳1526056649167 < 当前水印1526056650167，且对应的窗口已经关闭，直接被丢弃。
  3. 事件3到，水印跳到1526056651167，未到第二个窗口结束时间；作业终止时Flink会触发所有未关闭的窗口，输出事件2和3。

窗口大小4秒（4000ms）

• 窗口对齐后，三个事件全部落在同一个窗口：[1526056648000, 1526056652000)
• 事件处理流程：
  1. 事件2先到，水印1526056650167，未到窗口结束时间（1526056652000），窗口保持打开，事件2被加入。
  2. 事件1后到，时间戳1526056649167 < 当前水印，但窗口还没关闭，且该事件属于这个窗口，所以被正常加入。
  3. 事件3到，水印1526056651167，仍未到窗口结束时间；作业终止时触发窗口，输出全部三个事件。

二、TimeWindowAll的窗口起始时间确定规则 #

Flink的滚动窗口（timeWindowAll默认是滚动窗口）的起始时间是**严格对齐到Unix纪元时间（1970-01-01 00:00:00 UTC）**的，计算公式非常直观：

窗口起始时间 = 事件时间戳 - (事件时间戳 % 窗口大小毫秒值)
窗口结束时间 = 窗口起始时间 + 窗口大小毫秒值

窗口的区间是左闭右开的，即[起始时间, 结束时间)。

比如用事件2的时间戳1526056650167计算：

• 窗口大小4000ms：1526056650167 % 4000 = 2167，所以起始时间=1526056650167-2167=1526056648000，结束时间=1526056648000+4000=1526056652000，正好包含三个事件的时间戳。

补充说明 #

你看到的窗口大小7秒、8秒等输出全部三个事件的情况，本质是这三个事件的时间戳都落在了同一个窗口里，且事件1到达时窗口还没被水印触发关闭，所以被正常加入；而窗口大小3秒、5秒、6秒、10秒等情况，事件1和事件2/3分属不同窗口，且事件1到达时它所属的窗口已经被水印触发关闭，所以被丢弃。

另外，Flink在作业终止时会触发所有未关闭的窗口，这也是为什么即使水印没到窗口结束时间，最后也能看到窗口输出的原因。

内容的提问来源于stack exchange，提问作者Shay