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 2014/11/14 22:52:05 UTC
[13/17] storm git commit: fix intermittent test failure
fix intermittent test failure
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/69b5478f
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/69b5478f
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/69b5478f
Branch: refs/heads/master
Commit: 69b5478fdb987a54c3a78455d23224067e201ba0
Parents: 84b7e73
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Fri Nov 14 14:11:51 2014 -0500
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Fri Nov 14 14:11:51 2014 -0500
----------------------------------------------------------------------
external/storm-kafka/src/test/storm/kafka/KafkaUtilsTest.java | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/69b5478f/external/storm-kafka/src/test/storm/kafka/KafkaUtilsTest.java
----------------------------------------------------------------------
diff --git a/external/storm-kafka/src/test/storm/kafka/KafkaUtilsTest.java b/external/storm-kafka/src/test/storm/kafka/KafkaUtilsTest.java
index 34c9e1a..ae2fe6c 100644
--- a/external/storm-kafka/src/test/storm/kafka/KafkaUtilsTest.java
+++ b/external/storm-kafka/src/test/storm/kafka/KafkaUtilsTest.java
@@ -137,6 +137,7 @@ public class KafkaUtilsTest {
@Test
public void generateTuplesWithKeyAndKeyValueScheme() {
config.scheme = new KeyValueSchemeAsMultiScheme(new StringKeyValueScheme());
+ config.useStartOffsetTimeIfOffsetOutOfRange = false;
String value = "value";
String key = "key";
createTopicAndSendMessage(key, value);