[
https://issues.apache.org/jira/browse/FLINK-38543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-38543.
-----------------------------
Fix Version/s: 2.3.0
Resolution: Fixed
Merged to master(2.3.0) via:
* 8f40b51d623456420aa7e4cf1dc87d47acefe875
* aaab864c24d77979f8ae06771f30024ed323547e
* e39b252d383b47c2119551df89d90b8212eb6361
> Change the overall UC restore process, JM and task initialization
> -----------------------------------------------------------------
>
> Key: FLINK-38543
> URL: https://issues.apache.org/jira/browse/FLINK-38543
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / Checkpointing
> Reporter: Rui Fan
> Assignee: Rui Fan
> Priority: Major
> Labels: pull-request-available
> Fix For: 2.3.0
>
>
> When execution.checkpointing.unaligned.during-recovery.enabled is enabled,
> once all buffers are filtered：
> * Converting all remained buffers from Recovered Input Channel to
> RemoteInputChannel and LocalInputChannel
> * Then downstream requests partition to upstream tasks
> * Switching task state from INITIALIZING to RUNNING
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
