[
https://issues.apache.org/jira/browse/FLINK-38543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-38543:
----------------------------
Description:
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
was:
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
> 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
>
> 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)
