Repository: kafka
Updated Branches:
  refs/heads/0.10.1 aaefe686b -> ee212d1de


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

(cherry picked from commit c04486f4a5ec1101e6f1344658db359647ffa791)
Signed-off-by: Guozhang Wang <wangg...@gmail.com>


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/ee212d1d
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/ee212d1d
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/ee212d1d

Branch: refs/heads/0.10.1
Commit: ee212d1de3ca9b058364f34c5b8c30585298d51f
Parents: aaefe68
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:13 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/ee212d1d/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++;

Reply via email to