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

Head commit for run:
bda6d208c571641f75391f13b3089859174b426c / Chris Johnson <[email protected]>
[FLINK-40003][runtime] Fix IOMetrics not visible to state transition listeners

Execution.markFinished() and processFail() updated accumulators and
IOMetrics after transitionState(), so ExecutionStateUpdateListeners
notified inline during the transition saw null from getIOMetrics().

Add transitionToTerminalState() with a preCompletionAction callback that
runs after the state is set but before terminalStateFuture is completed
and listeners are notified. The metrics/accumulators update is passed as
this callback so both terminalStateFuture consumers and listeners observe
it. Applied to markFinished(), processFail(), completeCancelling() and
recoverExecution().

Co-Authored-By: Claude <[email protected]>
(cherry picked from commit c0f774fdcefab05cf25c986effaad78fa5ecff2a)

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

With regards,
GitHub Actions via GitBox

Reply via email to