Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-2491 Checkpointing only works if all operators/tasks are still running
  3. FLINK-21086

CheckpointBarrierHandler Insert barriers for channels received EndOfPartition

    XMLWordPrintableJSON

    Details

      Description

      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.

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              gaoyunhaii Yun Gao
            • Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

              • Created:
                Updated: