Apache Flink v1.4 Event Time窗口未触发问题排查求助

核心问题：API版本不兼容 #

Apache Flink v1.4 并不支持 WatermarkStrategy API，这个API是Flink 1.11及以上版本才引入的新特性。你在v1.4中使用该API，无法正确实现时间戳分配与水印生成逻辑，这是窗口未触发的根本原因。

具体修复步骤 #

1. 替换为Flink 1.4兼容的水印分配方式 #

在Flink 1.4中，需使用旧版的assignTimestampsAndWatermarks重载方法，结合AscendingTimestampExtractor（适用于单调递增的时间戳场景，对应你代码中的forMonotonousTimestamps）：

deviceVnetSource.assignTimestampsAndWatermarks(new AscendingTimestampExtractor<DataEngineMessage<String, DeviceVnet>>() {
    @Override
    public long extractAscendingTimestamp(DataEngineMessage<String, DeviceVnet> event) {
        // 将秒级时间戳转换为毫秒级
        return event.getValue().getTsSec() * 1000;
    }
})

2. 确保窗口逻辑正确启用 #

将注释的窗口代码恢复，并确认窗口配置符合预期（比如你提到的2秒滚动窗口）：

.keyBy(key -> key.getKey())
.window(TumblingEventTimeWindows.of(Time.seconds(2)))
.process(new UnifiedDistanceOperatorTest())

3. 验证水印与窗口触发条件 #

Event Time窗口触发的前提是水印时间 >= 窗口结束时间：

• 2秒滚动窗口的时间区间为[T, T+2000)，例如[1674113290000, 1674113292000)
• 只有当水印时间 >= 1674113292000时，该窗口才会触发
• 你日志中的水印1674113292999已经满足触发条件，修复API后窗口应该正常触发

额外检查点 #

• 确认event.getValue().getTsSec()返回的时间戳是正确的单调递增秒数，无乱序或无效值
• 检查作业是否正确调用了env.execute()方法（你的代码中未显示该调用，这是作业启动的必要步骤）

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