Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-2491 Support Checkpoints After Tasks Finished
  3. FLINK-21086

Support checkpoint alignment with finished input channels

    XMLWordPrintableJSON

Details

    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

      1.  For all the pending checkpoints, mark this channel as aligned.
      2. For the future checkpoints, excludes this channel.

      Attachments

        Activity

          People

            gaoyunhaii Yun Gao
            gaoyunhaii Yun Gao
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: