Rui Fan created FLINK-39522:
-------------------------------
Summary: Adapt input channels to consume from RecoveredBufferStore
Key: FLINK-39522
URL: https://issues.apache.org/jira/browse/FLINK-39522
Project: Flink
Issue Type: Sub-task
Reporter: Rui Fan
Assignee: Rui Fan
`RecoveredInputChannel`, `LocalInputChannel`, and `RemoteInputChannel` now read
recovery buffers via `store.tryTake()` instead of maintaining their own
recovered-buffer queue. Removes the `onRecoveredStateBuffer()` callback and the
`initialRecoveredBuffers` hand-off on channel conversion, wires
`store.checkpoint()` into `checkpointStarted()`, and routes in-use counts /
`releaseAllResources()` through the store.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
