Flink事件时间滚动窗口执行sum算子后无法输出结果问题咨询

核心前提说明 #

• 自定义ReduceFunction中打印的是增量聚合过程的中间日志，每接入一条窗口内的数据就会执行一次打印，不代表窗口已触发最终输出。
• sum算子、reduce后挂载的print算子，仅会在窗口正式触发计算时输出最终聚合结果。
• 事件时间滚动窗口的触发条件为：水印 ≥ 窗口的最大时间戳（5秒窗口[0,5000)的最大时间戳为4999，[5000,10000)的最大时间戳为9999）。

问题原因 #

1. 水印未达触发阈值，窗口未正式触发 #

这是最核心的原因：
你当前的测试数据最大时间戳为9999ms，符合以下任意场景时窗口都不会触发输出：

• 你使用无界数据源（Socket、Kafka等）测试，仅输入了6条测试数据，没有后续时间戳≥10000ms的输入，也未关闭数据源：此时水印最多推进到9999 - 乱序容忍时间 - 1，如果乱序容忍配置>0，水印会小于9999，达不到第二个窗口的触发阈值；如果水印配置错误，水印会一直停留在初始值，连第一个窗口都无法触发。
• 你配置的乱序容忍时间≥1ms：比如配置了forBoundedOutOfOrderness(Duration.ofMillis(1))，则最大时间戳为9999时，水印为9997 < 9999，第二个窗口无法触发。

2. 极少数索引适配问题（概率极低） #

如果使用Scala API，存在极小概率Flink无法正确识别Scala Tuple字段索引的问题，你当前sum(1)取Tuple第二个Int字段的逻辑是正确的，该情况出现概率极低。

解决方法 #

• 补充一条时间戳≥10000ms的测试数据，例如a,10000,7，此时水印会推进到≥9999，两个窗口都会触发，sum结果会正常打印。
• 如果是本地有限流测试，可在全部测试数据发送完成后主动关闭数据源，Flink会自动发送Long.MAX_VALUE的水印，触发所有未关闭的窗口输出结果。
• 无界流测试时可调整水印配置，将乱序容忍时间设置为0，确保水印能及时推进到窗口触发阈值。

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