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

StreamTask waits for all the asynchronous step of pending checkpoint to finish

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

    Details

      Description

      Currently the snapshot process contains the synchronous and asynchronous steps. When a StreamTask going to finish, there might be some pending checkpoints that are still running their asynchronous step. Currently StreamTask would abort these pending checkpoints since checkpoints after tasks finished are not support, and it need to be changed to StreamTask wait for these pending checkpoint to finish.

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              gaoyunhaii Yun Gao

              Dates

              • Created:
                Updated:

                Issue deployment