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
---