Repository: kafka Updated Branches: refs/heads/trunk d01f01ec6 -> 8c1e1cf27
KAFKA-6296; Increase jitter to fix transient failure in NetworkClientTest.testConnectionDelayDisconnected Author: Jason Gustafson <ja...@confluent.io> Reviewers: Ted Yu <yuzhih...@gmail.com>, Ewen Cheslack-Postava <e...@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 <ja...@confluent.io> Authored: Fri Dec 1 13:01:18 2017 -0800 Committer: Jason Gustafson <ja...@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); }
