Repository: kafka Updated Branches: refs/heads/trunk 704308a63 -> c04486f4a
HOTFIX: Increase number of retries in smoke test Author: Eno Thereska <eno.there...@gmail.com> Reviewers: Guozhang Wang <wangg...@gmail.com> Closes #2014 from enothereska/hotfix-smoke-test Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/c04486f4 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/c04486f4 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/c04486f4 Branch: refs/heads/trunk Commit: c04486f4a5ec1101e6f1344658db359647ffa791 Parents: 704308a Author: Eno Thereska <eno.there...@gmail.com> Authored: Wed Oct 12 12:45:00 2016 -0700 Committer: Guozhang Wang <wangg...@gmail.com> Committed: Wed Oct 12 12:45:00 2016 -0700 ---------------------------------------------------------------------- .../org/apache/kafka/streams/smoketest/SmokeTestDriver.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/c04486f4/streams/src/test/java/org/apache/kafka/streams/smoketest/SmokeTestDriver.java ---------------------------------------------------------------------- diff --git a/streams/src/test/java/org/apache/kafka/streams/smoketest/SmokeTestDriver.java b/streams/src/test/java/org/apache/kafka/streams/smoketest/SmokeTestDriver.java index b22d8a7..f9d30d5 100644 --- a/streams/src/test/java/org/apache/kafka/streams/smoketest/SmokeTestDriver.java +++ b/streams/src/test/java/org/apache/kafka/streams/smoketest/SmokeTestDriver.java @@ -222,7 +222,7 @@ public class SmokeTestDriver extends SmokeTestUtil { } int retryCount = 0; - int maxRetry = 240; // max two minutes (500ms * 240) (before we reach the end of records) + int maxRetry = 360; // max three minutes (500ms * 360) (before we reach the end of records) while (true) { ConsumerRecords<byte[], byte[]> records = consumer.poll(500); @@ -240,8 +240,8 @@ public class SmokeTestDriver extends SmokeTestUtil { if (value != null && value == END) { keys.remove(key); if (keys.isEmpty()) { - // we reached the end of records, set retry to 60 (max 30 seconds) - maxRetry = 60; + // we reached the end of records, set retry to 120 (max 60 seconds) + maxRetry = 120; } } else { recordsProcessed++;
