You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by mc...@apache.org on 2019/06/30 17:44:04 UTC
[incubator-pinot] branch increase-wait-time updated: Give the zk
server some time to start before trying to connect to it
This is an automated email from the ASF dual-hosted git repository.
mcvsubbu pushed a commit to branch increase-wait-time
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git
The following commit(s) were added to refs/heads/increase-wait-time by this push:
new 32038b2 Give the zk server some time to start before trying to connect to it
32038b2 is described below
commit 32038b2c31902fc1292bc88a53feef092a618dc7
Author: Subbu Subramaniam <ss...@linkedin.com>
AuthorDate: Sun Jun 30 10:43:22 2019 -0700
Give the zk server some time to start before trying to connect to it
---
.../src/main/java/org/apache/pinot/common/utils/ZkStarter.java | 3 +++
1 file changed, 3 insertions(+)
diff --git a/pinot-common/src/main/java/org/apache/pinot/common/utils/ZkStarter.java b/pinot-common/src/main/java/org/apache/pinot/common/utils/ZkStarter.java
index 0941d19..f0c1faa 100644
--- a/pinot-common/src/main/java/org/apache/pinot/common/utils/ZkStarter.java
+++ b/pinot-common/src/main/java/org/apache/pinot/common/utils/ZkStarter.java
@@ -18,6 +18,7 @@
*/
package org.apache.pinot.common.utils;
+import com.google.common.util.concurrent.Uninterruptibles;
import java.io.File;
import java.io.IOException;
import java.net.InetSocketAddress;
@@ -161,6 +162,8 @@ public class ZkStarter {
}
}
}.start();
+ // Give the server some time to start before trying to connect to it.
+ Uninterruptibles.sleepUninterruptibly(500, TimeUnit.MILLISECONDS);
// Wait until the ZK server is started
ZkClient client = new ZkClient("localhost:" + port, 10000);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org