Github user HeartSaVioR commented on a diff in the pull request:
https://github.com/apache/storm/pull/2241#discussion_r158677185
--- Diff: storm-client/src/jvm/org/apache/storm/task/IOutputCollector.java
---
@@ -30,4 +31,5 @@
void ack(Tuple input);
void fail(Tuple input);
void resetTimeout(Tuple input);
+ void flush();
--- End diff --
I think this is like public API, but given that we ship the change to major
version only, I guess that might be fine. If we have alternatives it would be
better though.
---
