Details
-
Sub-task
-
Status: Closed
-
Major
-
Resolution: Fixed
-
None
Description
For a non-source task, if one of its precedent task has finished, the precedent task would send EndOfPartition to it. However, currently the CheckpointBarrierHandler could not support receiving EndOfPartitionEvent. To support checkpoint after some tasks finish, when received EndOfPartitionEvent the CheckpointBarrierHandler should
- For all the pending checkpoints, mark this channel as aligned.
- For the future checkpoints, excludes this channel.