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

Allows tasks to report operator subtask finish state

    XMLWordPrintableJSON

    Details

      Description

      Once an operator is fully finished (e.g., all its subtasks are finished) in one checkpoint, the state need to be recorded to skip the execution of this operator after recovery. Thus we should allow operators to report finished state so that CheckpointCoordinator could identify fully finished operators for each checkpoint.

        Attachments

          Activity

            People

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

              Dates

              • Created:
                Updated: