You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2016/10/12 19:45:06 UTC
kafka git commit: HOTFIX: Increase number of retries in smoke test
Repository: kafka
Updated Branches:
refs/heads/trunk 704308a63 -> c04486f4a
HOTFIX: Increase number of retries in smoke test
Author: Eno Thereska <en...@gmail.com>
Reviewers: Guozhang Wang <wa...@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 <en...@gmail.com>
Authored: Wed Oct 12 12:45:00 2016 -0700
Committer: Guozhang Wang <wa...@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++;