Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-14713

Show Attempt History in Vertex SubTask

    XMLWordPrintableJSON

    Details

    • Type: Improvement
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: None
    • Fix Version/s: None
    • Labels:
      None

      Description

      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.

      Proposed Changes

      Add SubtaskAllExecutionAttemptsDetailsHandler for failed attempt

      • return subtask all attempt and state
      • get prior attempts according to
      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));
           }
        }
      }
      

       

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              lining lining
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated: