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.


---

Reply via email to