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

Skip the execution of the fully finished operators after recovery

Attach filesAttach ScreenshotAdd voteVotersWatch issueWatchersLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

    Details

      Description

      After recovery we should skip the execution of fully finished operators to keep consistent:

      1. For sources (including legacy source and new source), they should directly emit EndOfPartition.
      2. For both source and non-source operators, their lifecycle methods like open/endOfInput/close should be skipped.

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              gaoyunhaii Yun Gao

              Dates

              • Created:
                Updated:

                Issue deployment