[
https://issues.apache.org/jira/browse/FLINK-14713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lining updated FLINK-14713:
---------------------------
Component/s: (was: Runtime / Web Frontend)
> Show Attempt History in 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
>
> 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)
