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)