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

jobRunningTs should be the timestamp that all tasks are running

    XMLWordPrintableJSON

Details

    Description

      Currently, we consider the timestamp that JobStatus is changed to RUNNING as jobRunningTs. But the JobStatus will be RUNNING once job starts schedule, so it doesn't mean all tasks are running(It doesn't include request TM resources from kubernetes/yarn, deploy tasks and restore states, these steps will take a lot of time).

      It will let the isStabilizing or estimating restart time are not accurate.

      Solution: jobRunningTs should be the timestamp that all tasks are running.

      It can be got from SubtasksTimesHeaders rest api.

      Attachments

        Activity

          People

            fanrui Rui Fan
            fanrui Rui Fan
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated: