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)
