You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2016/01/11 18:06:44 UTC
[2/4] storm git commit: fix unit test
fix unit test
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/6e621269
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/6e621269
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/6e621269
Branch: refs/heads/master
Commit: 6e621269ff5023c84e4efab30b0ab0c3ebe443f9
Parents: 5edd4ea
Author: Xin Wang <be...@163.com>
Authored: Tue Dec 29 11:20:47 2015 +0800
Committer: vesense <be...@163.com>
Committed: Tue Dec 29 12:17:40 2015 +0800
----------------------------------------------------------------------
.../src/test/java/org/apache/storm/hive/bolt/TestHiveBolt.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/6e621269/external/storm-hive/src/test/java/org/apache/storm/hive/bolt/TestHiveBolt.java
----------------------------------------------------------------------
diff --git a/external/storm-hive/src/test/java/org/apache/storm/hive/bolt/TestHiveBolt.java b/external/storm-hive/src/test/java/org/apache/storm/hive/bolt/TestHiveBolt.java
index 8e79c8c..159beda 100644
--- a/external/storm-hive/src/test/java/org/apache/storm/hive/bolt/TestHiveBolt.java
+++ b/external/storm-hive/src/test/java/org/apache/storm/hive/bolt/TestHiveBolt.java
@@ -380,10 +380,10 @@ public class TestHiveBolt {
bolt = new HiveBolt(hiveOptions);
bolt.prepare(config, null, new OutputCollector(collector));
- //The tick should NOT cause any acks since the batch was empty
+ //The tick should NOT cause any acks since the batch was empty except for acking itself
Tuple mockTick = MockTupleHelpers.mockTickTuple();
bolt.execute(mockTick);
- verifyZeroInteractions(collector);
+ verify(collector).ack(mockTick);
bolt.cleanup();
}