Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

{

    "attempts" : {

        "type" : "array",

        "items" : {

           "type" : "object",

           "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:job:SubtaskExecutionAttemptDetailsInfo",

              "properties" : {

                  "subtask" : {

                      "type" : "integer"

                    },

                  "status" : {

                      "type" : "string",

                      "enum" : [ "CREATED", "SCHEDULED", "DEPLOYING", "RUNNING", "FINISHED", "CANCELING", "CANCELED", "FAILED", "RECONCILING" ]

                   },

                "attempt" : {

                    "type" : "integer"

                },

        "host" : {

          "type" : "string"

        },

        "start-time" : {

          "type" : "integer"

        },

        "end-time" : {

          "type" : "integer"

        },

        "duration" : {

          "type" : "integer"

        },

        "metrics" : {

          "type" : "object",

          "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:job:metrics:IOMetricsInfo",

          "properties" : {

            "read-bytes" : {

              "type" : "integer"

            },

            "read-bytes-complete" : {

              "type" : "boolean"

            },

            "write-bytes" : {

              "type" : "integer"

            },

            "write-bytes-complete" : {

              "type" : "boolean"

            },

            "read-records" : {

              "type" : "integer"

            },

            "read-records-complete" : {

              "type" : "boolean"

            },

            "write-records" : {

              "type" : "integer"

            },

            "write-records-complete" : {

              "type" : "boolean"

            }

          }

        }

      }

    }

  }

}

  • I was proposing the following. In the 'subtasks' array we have objects of type SubtaskTimeInfo with only one added field 'attempt-num'.
  • add query parameter show-history, default value is false. If show-history is true return the information of attempt.
  • url: /jobs/:jobid/vertices/:vertexid/subtasktimes?show-history=true
  • response:

...