[GitHub] flink pull request #5115: [FLINK-7692] [metrics] Support user-defined variab...

[tony810430]

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

    https://github.com/apache/flink/pull/5115#discussion_r154968275
  
    --- 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 --
    
    Have addressed it.


---