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

Expose stage of task initialization

    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
              • Votes:
                0 Vote for this issue
                Watchers:
                8 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: