The GitHub Actions job "Flink CI (beta)" on flink.git/master has succeeded. Run started by GitHub user pnowojski (triggered by pnowojski).
Head commit for run: 695ccca9a04a11275ffb230024527e3f226b9ab8 / Piotr Nowojski <[email protected]> [FLINK-40101][runtime] Emit intermediate watermarks while firing timers With unaligned checkpoints + interruptible timers, an operator's output watermark could stall for hours (surviving restarts) because it only advances once an entire due-timer backlog drains in one uninterrupted pass — a large backlog (e.g. after a rescale) can outlast every single attempt. InternalTimerServiceImpl/InternalTimeServiceManagerImpl now track the highest watermark known to be fully fired even when interrupted partway, and MailboxWatermarkProcessor emits that as an intermediate watermark instead of withholding all progress. This progress lives in a new field, not currentWatermark, since currentWatermark's eager semantics are relied on elsewhere (WindowOperator cleanup timers, user ProcessFunctions). Emission is paced by a configurable interval (default 5s, 0 disables) via an internal no-op processing-time nudge, avoiding per-timer clock checks. Report URL: https://github.com/apache/flink/actions/runs/29846639597 With regards, GitHub Actions via GitBox
