Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-17012

Expose stage of task initialization

Attach filesAttach ScreenshotVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

    Details

    • Release Note:
      Task's RUNNING state was split into two states: INITIALIZING and RUNNING. Task is INITIALIZING while state is initialising and in case of unaligned checkpoints, until all of the in-flight data has been recovered.

      Description

      Currently a task switches to running before fully initialized, does not take state initialization and operator initialization(#open ) in to account, which may take long time to finish. As a result, there would be a weird phenomenon that all tasks are running but throughput is 0.

      I think it could be good if we can expose the initialization stage of tasks. What to you think?

        Attachments

        Issue Links

          Activity

            People

            • Assignee:
              akalashnikov Anton Kalashnikov
              Reporter:
              wenlong.lwl Wenlong Lyu

              Dates

              • Created:
                Updated:
                Resolved:

                Issue deployment