You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "lining (Jira)" <ji...@apache.org> on 2020/02/14 03:06:00 UTC

[jira] [Updated] (FLINK-14713) Show Attempt History in Vertex SubTask

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

lining updated FLINK-14713:
---------------------------
        Parent: FLINK-16050
    Issue Type: Sub-task  (was: Improvement)

> Show Attempt History in Vertex SubTask
> --------------------------------------
>
>                 Key: FLINK-14713
>                 URL: https://issues.apache.org/jira/browse/FLINK-14713
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Runtime / REST, Runtime / Web Frontend
>            Reporter: lining
>            Priority: Major
>
> Flink jobs could recovery by failover, but the user couldn't see any information about the jobs' failure. There isn't information about the failed attempt.
> h3. Proposed Changes
> h4. Add SubtaskAllExecutionAttemptsDetailsHandler for failed attempt
>  * return subtask all attempt and state
>  * get prior attempts according to
> {code:java}
> final AccessExecution execution = executionVertex.getCurrentExecutionAttempt();
> final int currentAttemptNum = execution.getAttemptNumber();
> if (currentAttemptNum > 0) {
>   for (int i = currentAttemptNum - 1; i >= 0; i--) {
>      final AccessExecution currentExecution = executionVertex.getPriorExecutionAttempt(i);
>      if (currentExecution != null) {
>         allAttempts.add(SubtaskExecutionAttemptDetailsInfo.create(currentExecution, metricFetcher, jobID, jobVertexID));
>      }
>   }
> }
> {code}
>  



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