The GitHub Actions job "Flink CI (beta)" on 
flink.git/fhueske-FLINK-39437-Support-interruptible-timers-in-PTFs has failed.
Run started by GitHub user fhueske (triggered by fhueske).

Head commit for run:
807ebc4f5e19bca478e332ca6c0c4bad6d7208f3 / Fabian Hueske <[email protected]>
[FLINK-39437][table] Support interruptible timers in PTFs

Override `useInterruptibleTimers()` in `AbstractProcessTableOperator` to
return `true`, activating the `MailboxWatermarkProcessor` for PTF operators.
This allows timer firing to be interrupted between mailbox iterations,
improving throughput by not blocking mailbox processing during large timer
batches.

Also reorder `processWatermark()` to call `ingestWatermarkEvent()` before
`super.processWatermark()`, ensuring all timer callbacks (including those
deferred across mailbox iterations) see a consistent watermark in the runner.
This matches the behavior of `WritableInternalTimeContext.currentWatermark()`,
which reads from the timer service and already sees the new watermark before
any timer fires.

Report URL: https://github.com/apache/flink/actions/runs/24574815975

With regards,
GitHub Actions via GitBox

Reply via email to