You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by pt...@apache.org on 2015/05/15 23:27:36 UTC
[16/27] storm git commit: Added missing ack for the tick
Added missing ack for the tick
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/d3dcd1bd
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/d3dcd1bd
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/d3dcd1bd
Branch: refs/heads/0.10.x-branch
Commit: d3dcd1bdfc56fa7aca6752afdd5588586fc1ec91
Parents: 6b00040
Author: Niels Basjes <nb...@bol.com>
Authored: Thu Oct 30 10:27:05 2014 +0100
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Fri May 15 15:27:14 2015 -0400
----------------------------------------------------------------------
external/storm-kafka/src/jvm/storm/kafka/bolt/KafkaBolt.java | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/d3dcd1bd/external/storm-kafka/src/jvm/storm/kafka/bolt/KafkaBolt.java
----------------------------------------------------------------------
diff --git a/external/storm-kafka/src/jvm/storm/kafka/bolt/KafkaBolt.java b/external/storm-kafka/src/jvm/storm/kafka/bolt/KafkaBolt.java
index 913843c..0a1e5fe 100644
--- a/external/storm-kafka/src/jvm/storm/kafka/bolt/KafkaBolt.java
+++ b/external/storm-kafka/src/jvm/storm/kafka/bolt/KafkaBolt.java
@@ -90,6 +90,7 @@ public class KafkaBolt<K, V> extends BaseRichBolt {
@Override
public void execute(Tuple input) {
if (input.isTick()) {
+ collector.ack(input);
return; // Do not try to send ticks to Kafka
}