Minor change in tests Project: http://git-wip-us.apache.org/repos/asf/incubator-samoa/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-samoa/commit/e0d5b313 Tree: http://git-wip-us.apache.org/repos/asf/incubator-samoa/tree/e0d5b313 Diff: http://git-wip-us.apache.org/repos/asf/incubator-samoa/diff/e0d5b313
Branch: refs/heads/master Commit: e0d5b3131bc7c904e47ea36e980e9e461c182bd4 Parents: 81d2959 Author: pwawrzyniak <[email protected]> Authored: Fri May 12 17:22:54 2017 +0200 Committer: nkourtellis <[email protected]> Committed: Fri Jul 21 21:12:18 2017 +0300 ---------------------------------------------------------------------- .../test/java/org/apache/samoa/streams/kafka/KafkaUtilsTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-samoa/blob/e0d5b313/samoa-api/src/test/java/org/apache/samoa/streams/kafka/KafkaUtilsTest.java ---------------------------------------------------------------------- diff --git a/samoa-api/src/test/java/org/apache/samoa/streams/kafka/KafkaUtilsTest.java b/samoa-api/src/test/java/org/apache/samoa/streams/kafka/KafkaUtilsTest.java index e2b36fd..8f77504 100644 --- a/samoa-api/src/test/java/org/apache/samoa/streams/kafka/KafkaUtilsTest.java +++ b/samoa-api/src/test/java/org/apache/samoa/streams/kafka/KafkaUtilsTest.java @@ -91,7 +91,7 @@ public class KafkaUtilsTest { private static String zkConnect; private static final Logger logger = Logger.getLogger(KafkaUtilsTest.class.getCanonicalName()); - private final long CONSUMER_TIMEOUT = 1000; + private final long CONSUMER_TIMEOUT = 1500; public KafkaUtilsTest() { } @@ -230,7 +230,7 @@ public class KafkaUtilsTest { instance.sendKafkaMessage(TOPIC_S, val); } // wait for Kafka a bit :) - Thread.sleep(CONSUMER_TIMEOUT); + Thread.sleep(2*CONSUMER_TIMEOUT); logger.log(Level.INFO, "Get results from Kafka"); ConsumerRecords<String, byte[]> records = consumer.poll(CONSUMER_TIMEOUT);
