Repository: hbase Updated Branches: refs/heads/branch-1.4 9f7df19df -> f6be6e0d7
Revert "HBASE-19102 TestZooKeeperMainServer fails with KeeperException" This reverts commit 9f7df19dfaff4df275d45e0ba9d0ffcd45612483. Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/f6be6e0d Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/f6be6e0d Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/f6be6e0d Branch: refs/heads/branch-1.4 Commit: f6be6e0d7b6eb552ba4ee8da61b6cdc4f9d7bb8a Parents: 9f7df19 Author: Michael Stack <st...@apache.org> Authored: Fri Nov 3 12:16:08 2017 -0700 Committer: Michael Stack <st...@apache.org> Committed: Fri Nov 3 12:16:08 2017 -0700 ---------------------------------------------------------------------- .../hadoop/hbase/zookeeper/ZooKeeperMainServer.java | 13 ------------- 1 file changed, 13 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/f6be6e0d/hbase-server/src/main/java/org/apache/hadoop/hbase/zookeeper/ZooKeeperMainServer.java ---------------------------------------------------------------------- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/zookeeper/ZooKeeperMainServer.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/zookeeper/ZooKeeperMainServer.java index 5415fd6..e81da59 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/zookeeper/ZooKeeperMainServer.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/zookeeper/ZooKeeperMainServer.java @@ -20,9 +20,7 @@ package org.apache.hadoop.hbase.zookeeper; import java.io.IOException; -import java.util.concurrent.TimeUnit; -import org.apache.curator.shaded.com.google.common.base.Stopwatch; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.HBaseConfiguration; import org.apache.hadoop.hbase.HBaseInterfaceAudience; @@ -50,15 +48,6 @@ public class ZooKeeperMainServer { public HACK_UNTIL_ZOOKEEPER_1897_ZooKeeperMain(String[] args) throws IOException, InterruptedException { super(args); - // Make sure we are connected before we proceed. Can take a while on some systems. If we - // run the command without being connected, we get ConnectionLoss KeeperErrorConnection... - Stopwatch stopWatch = Stopwatch.createStarted(); - while (!this.zk.getState().isConnected()) { - Thread.sleep(1); - if (stopWatch.elapsed(TimeUnit.SECONDS) > 10) { - throw new InterruptedException("Failed connect " + this.zk); - } - } } /** @@ -111,8 +100,6 @@ public class ZooKeeperMainServer { } } // If command-line arguments, run our hack so they are executed. - // ZOOKEEPER-1897 was committed to zookeeper-3.4.6 but elsewhere in this class we say - // 3.4.6 breaks command-processing; TODO. if (hasCommandLineArguments(args)) { HACK_UNTIL_ZOOKEEPER_1897_ZooKeeperMain zkm = new HACK_UNTIL_ZOOKEEPER_1897_ZooKeeperMain(newArgs);