The GitHub Actions job "Flink CI (beta)" on flink.git/release-2.3 has succeeded.
Run started by GitHub user fhueske (triggered by fhueske).

Head commit for run:
62b37ed22086b5bbaf26307fa51261aca442d8a2 / 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/24793443055

With regards,
GitHub Actions via GitBox

Reply via email to