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