-
Type:
Sub-task
-
Status: Open
-
Priority:
Major
-
Resolution: Unresolved
-
Affects Version/s: None
-
Fix Version/s: None
-
Component/s: API / DataStream, Runtime / Checkpointing
-
Labels:
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.