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

Expose stage of task initialization

    XMLWordPrintableJSON

Details

    • 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

              akalashnikov Anton Kalashnikov
              wenlong.lwl Wenlong Lyu
              Votes:
              0 Vote for this issue
              Watchers:
              10 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: