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

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

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

Yun Gao created FLINK-21086:
-------------------------------

             Summary: 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: Runtime / Checkpointing
            Reporter: Yun Gao


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)