[
https://issues.apache.org/jira/browse/FLINK-39522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-39522:
----------------------------
Summary: Rework StreamTask channel-state recovery into an async future
chain; start consumption only after filtering completes (was: Adapt input
channels to consume from RecoveredBufferStore)
> Rework StreamTask channel-state recovery into an async future chain; start
> consumption only after filtering completes
> ---------------------------------------------------------------------------------------------------------------------
>
> Key: FLINK-39522
> URL: https://issues.apache.org/jira/browse/FLINK-39522
> Project: Flink
> Issue Type: Sub-task
> Reporter: Rui Fan
> Assignee: Rui Fan
> Priority: Major
>
> `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)
