You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Zhijiang (Jira)" <ji...@apache.org> on 2020/05/12 08:46:00 UTC
[jira] [Closed] (FLINK-16536) Implement InputChannel state recovery
for unaligned checkpoint
[ https://issues.apache.org/jira/browse/FLINK-16536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Zhijiang closed FLINK-16536.
----------------------------
Resolution: Fixed
Merged in master: d7525baf093035c9b0fe125602814833388d1973
> Implement InputChannel state recovery for unaligned checkpoint
> --------------------------------------------------------------
>
> Key: FLINK-16536
> URL: https://issues.apache.org/jira/browse/FLINK-16536
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / Checkpointing, Runtime / Network
> Reporter: Zhijiang
> Assignee: Zhijiang
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.11.0
>
> Time Spent: 10m
> Remaining Estimate: 0h
>
> During recovery process for unaligned checkpoint, the input channel state should also be recovered besides with existing operator states.
> The InputGate would request buffer from local pool and then interact with ChannelStateReader to fill in the state data. The filled buffer would be inserted into respective InputChannel queue for processing in normal way.
> It should guarantee that the new data from upstream side should not overtake the input state data to avoid mis-order issue.
> Refer to more details by [https://docs.google.com/document/d/16_MOQymzxrKvUHXh6QFr2AAXIKt_2vPUf8vzKy4H_tU/edit]
--
This message was sent by Atlassian Jira
(v8.3.4#803005)