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

Posted to issues@flink.apache.org by "Yun Gao (Jira)" <ji...@apache.org> on 2021/01/22 04:04:00 UTC

[jira] [Updated] (FLINK-21086) CheckpointBarrierHandler Insert barriers into channels received EndOfPartition

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

Yun Gao updated FLINK-21086:
----------------------------
    Component/s: API / DataStream

> CheckpointBarrierHandler Insert barriers into channels received EndOfPartition
> ------------------------------------------------------------------------------
>
>                 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
>
> 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)