#39991·beam

[错误]: Flink 释放了等待检查点的记录的水印保持对象

作者: bvolpato创建于 2026年9月3日更新于 2026年9月17日
标签flinkP1

发生了什么? Flink 运行程序可以在 `@RequiresStableInput` 后的记录仍然缓冲的情况下发出输出水印。 与 Apache Beam 提交 `ffcbd7e464f8244bd623d23e7fa9fcc750e81bbb` 进行重新验证。