[jira] [Created] (FLINK-6183) TaskMetricGroup may not be cleanup when Task.run() is never called or exits early

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-6183) TaskMetricGroup may not be cleanup when Task.run() is never called or exits early

Shang Yuanchun (Jira)
Chesnay Schepler created FLINK-6183:
---------------------------------------

             Summary: TaskMetricGroup may not be cleanup when Task.run() is never called or exits early
                 Key: FLINK-6183
                 URL: https://issues.apache.org/jira/browse/FLINK-6183
             Project: Flink
          Issue Type: Bug
    Affects Versions: 1.3.0
            Reporter: Chesnay Schepler
            Priority: Blocker


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.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)