...
When users click the vertex timeline, display all the subtask attempts timeline with subtaskId-host-attemptId.
REST API Design
...
- ArchivedExecutionVertex adds method to return prior executions.
- get prior execution attempt
AccessExecution execution = executionVertex.getCurrentExecutionAttempt();
int currentAttemptNum = execution.getAttemptNumber();
JobID jobID = request.getPathParameter(JobIDPathParameter.class);
JobVertexID jobVertexID = request.getPathParameter(JobVertexIdPathParameter.class);
List<SubtaskExecutionAttemptDetailsInfo> allAttempts = new ArrayList<>();
allAttempts.add(SubtaskExecutionAttemptDetailsInfo.create(execution, metricFetcher, jobID, jobVertexID));
if (currentAttemptNum > 0) {
for (int i = currentAttemptNum - 1; i >= 0; i--) {
AccessExecution currentExecution = executionVertex.getPriorExecutionAttempt(i);
if (currentExecution != null) {
allAttempts.add(SubtaskExecutionAttemptDetailsInfo.create(currentExecution, metricFetcher, jobID, jobVertexID));
}
}
- by ArchivedExecutionVertex.getPriorExecutionAttempts()
- add SubtaskAllExecutionAttemptsDetailsHandler for failed attempt
- url /jobs/:jobid/vertices/:vertexid/subtasks/:subtaskIndex/attempts
- response:
...