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:
063b46ef66843868bde7de9f9366ffff3e53055e / Martijn Visser 
<[email protected]>
[FLINK-40011][table-planner] Fix NoMoreSplitsEvent race in CommonExecSinkITCase

The TestSource reader in CommonExecSinkITCase returned END_OF_INPUT as soon as
it had emitted its rows. The SingleSplitEnumerator assigns the split and then,
through the coordinator thread, delivers a NoMoreSplitsEvent as a separate
event. If the split-holding subtask finished before that event was delivered,
the coordinator sent it to an already-FINISHED task. The framework treats the
undeliverable event as a lost OperatorEvent and triggers a failover, which the
job's NoRestartBackoffTimeStrategy turns into a hard failure (observed once, in
build 76431, on subtask (1/4), the split holder).

Defer END_OF_INPUT until notifyNoMoreSplits() has been received so the reader
cannot finish before the event lands, mirroring how
SourceReaderBase.finishedOrAvailableLater() defers completion until
no-more-splits is set. This is the chosen approach for this test, not a general
source-reader requirement. No emitted data or assertion changes.

Generated-by: Claude Opus 4.8 (1M context)

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

With regards,
GitHub Actions via GitBox

Reply via email to