[ https://issues.apache.org/jira/browse/FLINK-21086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
ASF GitHub Bot updated FLINK-21086: ----------------------------------- Labels: pull-request-available (was: ) > CheckpointBarrierHandler Insert barriers for 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 > 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)