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 <[email protected]> Authored: Fri Nov 14 14:11:51 2014 -0500 Committer: P. Taylor Goetz <[email protected]> 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);
