[helix] branch master updated: Small bug fixes related to ZK disconnect. (#2486)

[xyuanlu]

This is an automated email from the ASF dual-hosted git repository.

xyuanlu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/helix.git


The following commit(s) were added to refs/heads/master by this push:
     new 9d5b82e66 Small bug fixes related to ZK disconnect. (#2486)
9d5b82e66 is described below

commit 9d5b82e66ed99bc00f0398b658fa04c1beee7c0a
Author: Komal Desai <98000016+desaiko...@users.noreply.github.com>
AuthorDate: Tue May 16 17:37:06 2023 -0700

    Small bug fixes related to ZK disconnect. (#2486)
    
    with exponential backoff in retry logic, test had become flaky. Explicitly 
wait for thread to join and remove the randomness.
    
    Co-authored-by: Komal Desai <kde...@kdesai-mn1.linkedin.biz>
---
 .../java/org/apache/helix/integration/TestZkConnectionLost.java     | 2 +-
 .../src/main/java/org/apache/helix/zookeeper/zkclient/ZkClient.java | 2 +-
 .../org/apache/helix/zookeeper/impl/client/TestRawZkClient.java     | 6 +++---
 3 files changed, 5 insertions(+), 5 deletions(-)

diff --git 
a/helix-core/src/test/java/org/apache/helix/integration/TestZkConnectionLost.java
 
b/helix-core/src/test/java/org/apache/helix/integration/TestZkConnectionLost.java
index b42752937..f141766ab 100644
--- 
a/helix-core/src/test/java/org/apache/helix/integration/TestZkConnectionLost.java
+++ 
b/helix-core/src/test/java/org/apache/helix/integration/TestZkConnectionLost.java
@@ -132,7 +132,7 @@ public class TestZkConnectionLost extends TaskTestBase {
     };
     try {
       testThread.start();
-      testThread.join(10000);
+      testThread.join();
       Assert.assertTrue(disconnected.get());
       Assert.assertFalse(controllerManager.isConnected());
     } finally {
diff --git 
a/zookeeper-api/src/main/java/org/apache/helix/zookeeper/zkclient/ZkClient.java 
b/zookeeper-api/src/main/java/org/apache/helix/zookeeper/zkclient/ZkClient.java
index da9a54303..78a3c88ed 100644
--- 
a/zookeeper-api/src/main/java/org/apache/helix/zookeeper/zkclient/ZkClient.java
+++ 
b/zookeeper-api/src/main/java/org/apache/helix/zookeeper/zkclient/ZkClient.java
@@ -1955,7 +1955,7 @@ public class ZkClient implements Watcher {
     if (_monitor != null) {
       _monitor.increaseOutstandingRequestGauge();
     }
-    int retryCount = 1;
+    int retryCount = 0;
     long currTime = System.currentTimeMillis();
     try {
       while (true) {
diff --git 
a/zookeeper-api/src/test/java/org/apache/helix/zookeeper/impl/client/TestRawZkClient.java
 
b/zookeeper-api/src/test/java/org/apache/helix/zookeeper/impl/client/TestRawZkClient.java
index ca371616a..e5b589ff8 100644
--- 
a/zookeeper-api/src/test/java/org/apache/helix/zookeeper/impl/client/TestRawZkClient.java
+++ 
b/zookeeper-api/src/test/java/org/apache/helix/zookeeper/impl/client/TestRawZkClient.java
@@ -832,7 +832,7 @@ public class TestRawZkClient extends ZkTestBase {
       final boolean creationThreadTerminated = countDownLatch.await(10L, 
TimeUnit.SECONDS);
       if (!creationThreadTerminated) {
         running.set(false);
-        creationThread.join(5000L);
+        creationThread.join();
         Assert.fail("Failed to receive a ConnectionLossException after 
zookeeper has shutdown.");
       }
     } finally {
@@ -893,7 +893,7 @@ public class TestRawZkClient extends ZkTestBase {
     final boolean creationThreadTerminated = countDownLatch.await(10, 
TimeUnit.SECONDS);
     if (!creationThreadTerminated) {
       running.set(false);
-      creationThread.join(5000L);
+      creationThread.join();
       Assert.fail("Failed to reconnect to zk server and create ephemeral node"
           + " after zk server is recovered.");
     }
@@ -966,7 +966,7 @@ public class TestRawZkClient extends ZkTestBase {
     final boolean creationThreadTerminated = countDownLatch.await(10, 
TimeUnit.SECONDS);
     if (!creationThreadTerminated) {
       running.set(false);
-      creationThread.join(5000L);
+      creationThread.join();
       Assert.fail("Failed to reconnect to zk server and create ephemeral node"
           + " after zk server is recovered.");
     }