flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-6183) TaskMetricGroup may not be cleanup when Task.run() is never called or exits early
Date Tue, 28 Mar 2017 18:39:41 GMT

    [ https://issues.apache.org/jira/browse/FLINK-6183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15945700#comment-15945700
] 

ASF GitHub Bot commented on FLINK-6183:
---------------------------------------

Github user zentol commented on a diff in the pull request:

    https://github.com/apache/flink/pull/3610#discussion_r108503328
  
    --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/TaskManagerJobMetricGroup.java
---
    @@ -80,8 +80,17 @@ public TaskMetricGroup addTask(
     					taskName,
     					subtaskIndex,
     					attemptNumber);
    -				tasks.put(executionAttemptID, task);
    -				return task;
    +				TaskMetricGroup prior = tasks.put(executionAttemptID, task);
    +				if (prior == null) {
    +					return task;
    --- End diff --
    
    yes that would work as well.


> 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
>          Components: Metrics
>    Affects Versions: 1.2.0, 1.3.0
>            Reporter: Chesnay Schepler
>            Assignee: 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)

Mime
View raw message