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

Improve logs to better display Execution

    XMLWordPrintableJSON

Details

    Description

      Currently, an execution is usually represented as "job vertex name (subtaskIndex+1/vertex parallelism) (attemptId)" in logs, which may be redundant after this refactoring work. With the change of FLINK-17295, the representation of Execution in logs will be redundant. e.g. the subtask index is displayed 2 times.

      Therefore, I'm proposing to change the format to be "<job vertex name> {}(<subtaskIndex>+1/<vertex parallelism>) #<attemptNumber>  (graph: <short ExecutionGraphID>, vertex: <JobVertexID>) " and avoid directly display the ExecutionAttemptID. This can increase the log readability.

      Attachments

        Issue Links

          Activity

            People

              zhuzh Zhu Zhu
              zhuzh Zhu Zhu
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated: