You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by lo...@apache.org on 2016/03/01 00:58:27 UTC
[04/13] storm git commit: Acker bolt should return after processing
timeout tick tuple
Acker bolt should return after processing timeout tick tuple
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/c4dfa33c
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/c4dfa33c
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/c4dfa33c
Branch: refs/heads/master
Commit: c4dfa33c58ac8e1d3c6197b86b2976b9669a39f3
Parents: e50a312
Author: basti.lj <ba...@alibaba-inc.com>
Authored: Wed Feb 3 18:43:17 2016 +0800
Committer: basti.lj <ba...@alibaba-inc.com>
Committed: Wed Feb 3 18:43:17 2016 +0800
----------------------------------------------------------------------
storm-core/src/jvm/org/apache/storm/daemon/AckerBolt.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/c4dfa33c/storm-core/src/jvm/org/apache/storm/daemon/AckerBolt.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/daemon/AckerBolt.java b/storm-core/src/jvm/org/apache/storm/daemon/AckerBolt.java
index 80ed4ca..a4f6815 100644
--- a/storm-core/src/jvm/org/apache/storm/daemon/AckerBolt.java
+++ b/storm-core/src/jvm/org/apache/storm/daemon/AckerBolt.java
@@ -67,6 +67,7 @@ public class AckerBolt implements IBolt {
if (TupleUtils.isTick(input)) {
Map<Object, AckObject> tmp = pending.rotate();
LOG.debug("Number of timeout tuples:{}", tmp.size());
+ return;
}
String streamId = input.getSourceStreamId();
@@ -115,8 +116,6 @@ public class AckerBolt implements IBolt {
collector.emitDirect(task, ACKER_FAIL_STREAM_ID, values);
}
}
- } else {
-
}
collector.ack(input);