InputChannel for local communication does not properly support checkpointing with recovered buffers

InputChannel for local communication does not properly support checkpointing with recovered buffers: a task in LegoFlow-SWE (Harbor dataset). Flink’s network stack relies on InputChannel for local data exchange. When a task fails and recovers, in‑flight buffers may be preserved and stored in…

The task

Flink’s network stack relies on `InputChannel` for local data exchange. When a task fails and recovers, in‑flight buffers may be preserved and stored in `toBeConsumedBuffers`. The local `InputChannel` implementation currently mishandles several aspects of checkpointing in this recovery scenario, putting exactly‑once…

Part of Lego-X/LegoFlow-SWE.