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

    https://github.com/apache/flink/pull/5734#discussion_r176028213
  
    --- Diff: 
flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
 ---
    @@ -265,7 +265,11 @@ class TaskManager(
           case t: Exception => log.error("FileCache did not shutdown 
properly.", t)
         }
     
    -    taskManagerMetricGroup.close()
    +    try {
    +      taskManagerMetricGroup.close()
    --- End diff --
    
    same as above


---

Reply via email to