MartijnVisser opened a new pull request, #29346: URL: https://github.com/apache/flink/pull/29346
Backport of https://github.com/apache/flink/pull/29024 (bb773b5fb8a), which went to master but not to this branch. The FLINK-40504 backport #29331 should be merged after this one: it marks a source active again when it resumes without advancing its watermark. Without this fix, the valve then skips the all-idle flush if that input is still behind the valve's watermark when it is the last one to go idle. This changes behaviour on a patch release, see the Release Note on FLINK-40475: once all inputs are idle, windows and timers can fire earlier than before. Verified locally on JDK 17: the three new `StatusWatermarkValveTest` cases fail with the valve of the base commit and pass with this change. The watermark and source operator tests in `flink-core` and `flink-runtime`, `OneInputStreamTaskTest`, `TwoInputStreamTaskTest`, `MultipleInputStreamTaskTest` and `spotless:check` pass. ##### Was generative AI tooling used to co-author this PR? - [X] Yes (please specify the tool below) Generated-by: Claude Code (Claude Opus 5.5) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
