PyFlink Watermark始终卡在-9223372036854775808不推进如何解决

你遇到的Watermark不推进问题是有限流测试场景下的典型现象，核心原因如下：

• 你使用from_collection加载的是有限静态数据集，Flink处理有限流时，默认只会在整个分片的所有数据全部读取完成后，一次性发送最大值水位线（9223372036854775807）来触发所有剩余定时器，数据处理过程中不会周期性更新水位线，所以你在process_element方法中拿到的永远是初始值-9223372036854775808。
• 你设置的set_auto_watermark_interval(1)单位为毫秒，过小的间隔对于小体量的有限数据集没有意义，Source算子会在数毫秒内读完所有数据，还没到第一次水位线发送时机就已经进入流结束逻辑。
• Flink 1.13之前的版本中，from_collection这类内置有限源本身不支持运行中周期性生成水位线，仅Kafka、Socket这类持续流源会在运行过程中动态推送水位线。

• 测试EventTime和定时器逻辑时，建议替换为持续流数据源（比如Socket文本流），模拟实时数据输入，即可观察到水位线的动态推进效果。
• 若必须使用有限流测试，可以在数据集末尾插入一条携带最大时间戳的标记数据，强制触发水位线更新；也可以自定义Watermark生成策略，在处理过程中主动推进水位线。
• 将自动水位线间隔调整为合理值（比如200ms），避免过小的间隔带来不必要的性能开销。

你在on_timer方法中拿到的最大值水位线是正常的，这是Flink在流结束时发送的终止水位线，用来触发所有未触发的事件时间定时器。

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