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/29 07:57:00 UTC

[jira] [Assigned] (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 reassigned FLINK-21086:
----------------------------------------

    Assignee: Yun Gao

> 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
>            Assignee: 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. However, currently the CheckpointBarrierHandler could not support receiving EndOfPartitionEvent. To support checkpoint after some tasks finish, when received EndOfPartitionEvent the CheckpointBarrierHandler should
> #  For all the pending checkpoints, mark this channel as aligned.
> #  For the future checkpoints, excludes this channel. 



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