The GitHub Actions job "maven in /flink-libraries/flink-table for 
org.apache.calcite:calcite-core - Update #1456117460" on flink.git/master has 
failed.
Run started by GitHub user dependabot[bot] (triggered by dependabot[bot]).

Head commit for run:
c2f0c123409285cb244c23b32cc108dea2a9a990 / Rui Fan <[email protected]>
[FLINK-39521][network] CheckpointedInputGate: consume 
EndOfFetchedChannelStateEvent

When the consume path polls the EndOfFetchedChannelStateEvent sentinel,
assert the originating channel is a RecoverableInputChannel and call its
onRecoveredStateConsumed(): the channel flips out of recovery, releases
any upstream events held back during recovery and reopens the upstream so
live data may flow again. The event itself is never delivered to the
operator.

The sentinel-consumption path is exercised end to end by the
Local/RemoteInputChannel recovery tests of this PR
(onRecoveredStateConsumed after polling the sentinel) and by the
StreamTask recovery tests of the follow-up PRs.

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

With regards,
GitHub Actions via GitBox

Reply via email to