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)