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---
