[ 
https://issues.apache.org/jira/browse/FLINK-14713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

ASF GitHub Bot updated FLINK-14713:
-----------------------------------
    Labels: pull-request-available  (was: )

> Show All Attempts For Vertex SubTask In Rest Api
> ------------------------------------------------
>
>                 Key: FLINK-14713
>                 URL: https://issues.apache.org/jira/browse/FLINK-14713
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Runtime / REST
>            Reporter: lining
>            Priority: Major
>              Labels: pull-request-available
>
> Flink jobs could recovery by failover, but the user couldn't see any 
> information about the jobs' failure. There isn't information about the 
> historical attempt.
> h3. Proposed Changes
> h4. Add SubtaskAllExecutionAttemptsDetailsHandler for failed attempt
>  * return subtask all attempt and state
>  * AccessExecutionVertex add method to returns the prior executions
>  * get prior attempts according to 
> AccessExecutionVertex.getPriorExecutionAttempts
>  * add SubtaskAllExecutionAttemptsDetailsHandler for prior attempt
>  * url /jobs/:jobid/vertices/:vertexid/subtasks/:subtaskIndex/attempts
>  * response:
> {code:json}
> {
>   "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"
>             }
>           }
>         }
>       }
>     }
>   }
> }
> {code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to