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

    https://github.com/apache/storm/pull/2399#discussion_r148330213
  
    --- Diff: storm-client/src/jvm/org/apache/storm/messaging/netty/Server.java 
---
    @@ -249,6 +250,15 @@ public Object getState() {
                 }
             }
             ret.put("enqueued", enqueued);
    +        
    +        // Report messageSizes metric
    +        if (_cb instanceof IMetric) {
    +            Object metrics = ((IMetric) _cb).getValueAndReset();
    +            if(metrics instanceof Map && !((Map) metrics).isEmpty()) {
    --- End diff --
    
    nit: space after the if


---

Reply via email to