kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: HOTFIX: Increase number of retries in smoke test
Date Wed, 12 Oct 2016 19:45:06 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 704308a63 -> c04486f4a


HOTFIX: Increase number of retries in smoke test

Author: Eno Thereska <eno.thereska@gmail.com>

Reviewers: Guozhang Wang <wangguoz@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.thereska@gmail.com>
Authored: Wed Oct 12 12:45:00 2016 -0700
Committer: Guozhang Wang <wangguoz@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++;


Mime
View raw message