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

TaskMetricGroup may not be cleanup when Task.run() is never called or exits early

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Blocker
    • Resolution: Fixed
    • Affects Version/s: 1.2.0, 1.3.0
    • Fix Version/s: 1.2.1, 1.3.0
    • Component/s: Metrics
    • Labels:
      None

      Description

      The TaskMetricGroup is created when a Task is created. It is cleaned up at the end of Task.run() in the finally block. If however run() is never called due some failure between the creation and the call to run the metric group is never closed. This also means that the JobMetricGroup is never closed.

        Attachments

          Activity

            People

            • Assignee:
              Zentol Chesnay Schepler
              Reporter:
              Zentol Chesnay Schepler
            • Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: