Github user Ethanlm commented on a diff in the pull request:
https://github.com/apache/storm/pull/2641#discussion_r183395986
--- Diff:
examples/storm-hdfs-examples/src/main/java/org/apache/storm/hdfs/bolt/SequenceFileTopology.java
---
@@ -151,15 +145,15 @@ public void nextTuple() {
}
count++;
total++;
- if(count > 20000){
+ if (count > 20000) {
count = 0;
System.out.println("Pending count: " + this.pending.size()
+ ", total: " + this.total);
}
Thread.yield();
}
public void ack(Object msgId) {
-// System.out.println("ACK");
+ // System.out.println("ACK");
--- End diff --
Should we just remove this
---
