flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "lining (Jira)" <j...@apache.org>
Subject [jira] [Created] (FLINK-14713) Show Attempt History in Vertex SubTask
Date Tue, 12 Nov 2019 06:47:00 GMT
lining created FLINK-14713:
------------------------------

             Summary: Show Attempt History in Vertex SubTask
                 Key: FLINK-14713
                 URL: https://issues.apache.org/jira/browse/FLINK-14713
             Project: Flink
          Issue Type: Improvement
          Components: Runtime / REST, Runtime / Web Frontend
            Reporter: lining


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)

Mime
View raw message