kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject kafka git commit: KAFKA-6296; Increase jitter to fix transient failure in NetworkClientTest.testConnectionDelayDisconnected
Date Fri, 01 Dec 2017 21:03:54 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk d01f01ec6 -> 8c1e1cf27


KAFKA-6296; Increase jitter to fix transient failure in NetworkClientTest.testConnectionDelayDisconnected

Author: Jason Gustafson <jason@confluent.io>

Reviewers: Ted Yu <yuzhihong@gmail.com>, Ewen Cheslack-Postava <ewen@confluent.io>

Closes #4285 from hachikuji/KAFKA-6296


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

Branch: refs/heads/trunk
Commit: 8c1e1cf27a58d7433c0230ff2b8ecefb30f73fd0
Parents: d01f01e
Author: Jason Gustafson <jason@confluent.io>
Authored: Fri Dec 1 13:01:18 2017 -0800
Committer: Jason Gustafson <jason@confluent.io>
Committed: Fri Dec 1 13:01:18 2017 -0800

----------------------------------------------------------------------
 .../test/java/org/apache/kafka/clients/NetworkClientTest.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/8c1e1cf2/clients/src/test/java/org/apache/kafka/clients/NetworkClientTest.java
----------------------------------------------------------------------
diff --git a/clients/src/test/java/org/apache/kafka/clients/NetworkClientTest.java b/clients/src/test/java/org/apache/kafka/clients/NetworkClientTest.java
index edbd72d..b966494 100644
--- a/clients/src/test/java/org/apache/kafka/clients/NetworkClientTest.java
+++ b/clients/src/test/java/org/apache/kafka/clients/NetworkClientTest.java
@@ -284,7 +284,7 @@ public class NetworkClientTest {
         client.poll(requestTimeoutMs, time.milliseconds());
         long delay = client.connectionDelay(node, time.milliseconds());
         long expectedDelay = reconnectBackoffMsTest;
-        double jitter = 0.2;
+        double jitter = 0.3;
         assertEquals(expectedDelay, delay, expectedDelay * jitter);
 
         // Sleep until there is no connection delay
@@ -299,7 +299,7 @@ public class NetworkClientTest {
         // Second attempt should take twice as long with twice the jitter
         expectedDelay = Math.round(delay * 2);
         delay = client.connectionDelay(node, time.milliseconds());
-        jitter = 0.4;
+        jitter = 0.6;
         assertEquals(expectedDelay, delay, expectedDelay * jitter);
     }
 


Mime
View raw message