THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
- add Collection<SubtaskTimeInfo> in SubtasksTimesHandler result, which comes from ExecutionVertex’s prior executions.
- add query parameter show-history, default value is false. if show-history is true return the information of attempt, else return emtpy array.
- url: /jobs/:jobid/vertices/:vertexid/subtasktimes
- response
...
{ "type" : "object", "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:SubtasksTimesInfo", "properties" : { "id" : { "type" : "string" }, "name" : { "type" : "string" }, "now" : { "type" : "integer" }, "subtasks" : { "type" : "array", "items" : { "type" : "object", "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:SubtasksTimesInfo:SubtaskTimeInfo", "properties" : { "subtask" : { "type" : "integer" }, "host" : { "type" : "string" }, "duration" : { "type" : "integer" }, "timestamps" : { "type" : "object", "additionalProperties" : { "type" : "integer" } }, "attempt-num": { "type" : "integer" }, "attempts-time-info": { "type": "array", "items" : { "type" : "object", "id" : "urn:jsonschema:org:apache:flink:runtime:rest:messages:SubtaskAttemptTimeInfo", "properties" : { "subtask" : { "type" : "integer" }, "host" : { "type" : "string" }, "duration" : { "type" : "integer" }, "timestamps" : { "type" : "object", "additionalProperties" : { "type" : "integer" } }, "attempt-num": { "type" : "integer" }, } } } } } } } } |
...