You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/06/23 07:45:00 UTC

[jira] [Updated] (FLINK-21086) Support checkpoint alignment with finished input channels

     [ https://issues.apache.org/jira/browse/FLINK-21086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Dawid Wysakowicz updated FLINK-21086:
-------------------------------------
    Summary: Support checkpoint alignment with finished input channels  (was: Make checkpointBarrierHandler Support EndOfPartition)

> Support checkpoint alignment with finished input channels
> ---------------------------------------------------------
>
>                 Key: FLINK-21086
>                 URL: https://issues.apache.org/jira/browse/FLINK-21086
>             Project: Flink
>          Issue Type: Sub-task
>          Components: API / DataStream, Runtime / Checkpointing
>            Reporter: Yun Gao
>            Priority: Major
>              Labels: pull-request-available
>
> For a non-source task, if one of its precedent task has finished, the precedent task would send EndOfPartition to it. Then for checkpoint after that, this task would not receive the barrier from the channel that has sent EndOfPartition. To finish the alignment, CheckpointBarrierHandler would insert barriers before EndOfPartition for these channels.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)