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

• 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: Runtime / Metrics
• Assignee: Chesnay Schepler
• Reporter: Chesnay Schepler
• Created: 24/Mar/17 17:14
• Updated: 05/Apr/17 21:29
• Resolved: 05/Apr/17 21:27

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.

Issue Links

• links to: GitHub Pull Request #3610
• links to: GitHub Pull Request #3611