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:17:00 UTC
[jira] [Updated] (FLINK-14713) Show Attempt History in Vertex
SubTask In Rest Api
[ 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)