[
https://issues.apache.org/jira/browse/FLINK-39018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-39018.
-----------------------------
Fix Version/s: 2.3.0
Resolution: Fixed
Merged to master(2.3.0) via: 3aef0932ded1a1ece9943915c681e1fe33433700,
cebc174ad5f86716aba5b54017269e7263b6dec0,
4f192b3323891adb3b9b8dda7de62d14b901c570 and
d1914c63c95715086884fee20cfe08fe8388547b
> 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
> Labels: pull-request-available
> Fix For: 2.3.0
>
>
> 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)
