Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5115#discussion_r154965270 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/AbstractMetricGroup.java --- @@ -441,14 +441,14 @@ private MetricGroup addGroup(String name, boolean keyed) { } else { // return a non-registered group that is immediately closed already - GenericMetricGroup closedGroup = createChildGroup(name); + GenericMetricGroup closedGroup = createChildGroupInKeyedContext(name); --- End diff -- Lets return a GenericMetricGroup here to keep this case as simple as possible.
---