[
https://issues.apache.org/jira/browse/FLINK-39018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-39018:
----------------------------
Description:
The current master branch does not support (unaligned) checkpoint during
recovery.
For normal unaligned checkpoint:
* Only RemoteInputChannel supports checkpoint
* And LocalInputChannel does not support checkpoint since all buffers are
stored in the ResultSubpartition of upstream task.
The LocalInputChannel needs to supports checkpoint when supporting checkpoint
during recovery, since some recovered buffers will be converted from
LocalRecoveredInputChannel to LocalInputChannel, and they have to be
snapshotted during recovery via LocalInputChannel.
> Support checkpoint for LocalInputChannel
> ----------------------------------------
>
> Key: FLINK-39018
> URL: https://issues.apache.org/jira/browse/FLINK-39018
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / Checkpointing, Runtime / Network
> Reporter: Rui Fan
> Assignee: Rui Fan
> Priority: Major
>
> The current master branch does not support (unaligned) checkpoint during
> recovery.
> For normal unaligned checkpoint:
> * Only RemoteInputChannel supports checkpoint
> * And LocalInputChannel does not support checkpoint since all buffers are
> stored in the ResultSubpartition of upstream task.
> The LocalInputChannel needs to supports checkpoint when supporting checkpoint
> during recovery, since some recovered buffers will be converted from
> LocalRecoveredInputChannel to LocalInputChannel, and they have to be
> snapshotted during recovery via LocalInputChannel.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
