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

    https://github.com/apache/flink/pull/5115#discussion_r154907808
  
    --- Diff: 
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/AbstractMetricGroup.java
 ---
    @@ -409,6 +404,22 @@ public MetricGroup addGroup(String name) {
                return addGroup(name, false);
        }
     
    +   @Override
    +   public MetricGroup addGroup(String key, String value) {
    --- End diff --
    
    In the below case, the `subGroup2` will get a `GenericValueMetricGroup` 
back.
    ```
    val subGroup = group.addGroup("key", "value")
    val subGroup2 = group.addGroup("key").addGroup("value")
    ```
    I prefer not to change the behavior of original API, so I think it is 
better to return a `GenericMetricGroup`.


---

Reply via email to