The GitHub Actions job "Nightly (beta)" on flink.git/master has failed.
Run started by GitHub user github-actions[bot] (triggered by 
github-actions[bot]).

Head commit for run:
5106d15e83d4497824c33b71fd0021846bd1ec09 / Fabian Hueske <[email protected]>
[FLINK-39437][table] Support interruptible timers in PTFs (#27962)

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 removes `currentWatermark` from `ProcessTableRunner` and redirect reads to 
`AbstractStreamOperatorV2.combinedWatermark`.

Add a test (`ProcessSetTableOperatorInterruptibleTimersTest`) to assert correct 
behavior
of PTF framework when timer processing is interrupted.

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

With regards,
GitHub Actions via GitBox

Reply via email to