Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

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:

...