Github user roshannaik commented on a diff in the pull request:
https://github.com/apache/storm/pull/2241#discussion_r158923506
--- Diff: storm-client/src/jvm/org/apache/storm/daemon/Task.java ---
@@ -177,6 +196,35 @@ public BuiltinMetrics getBuiltInMetrics() {
return builtInMetrics;
}
+
+ // Non Blocking call. If cannot emmit to destination immediately, such
tuples will be added to `pendingEmits` argument
--- End diff --
fixed.---
