Curator needs to be started before ServiceCache can be built.
Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/83fb40e9 Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/83fb40e9 Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/83fb40e9 Branch: refs/heads/master Commit: 83fb40e9aa05380f30ea18f92d6d0f8715c03204 Parents: ffdeab0 Author: Aditya Kishore <[email protected]> Authored: Sat Jun 7 13:50:18 2014 -0700 Committer: Jacques Nadeau <[email protected]> Committed: Sun Jun 8 19:13:06 2014 -0700 ---------------------------------------------------------------------- .../java/org/apache/drill/exec/coord/zk/ZKClusterCoordinator.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/83fb40e9/exec/java-exec/src/main/java/org/apache/drill/exec/coord/zk/ZKClusterCoordinator.java ---------------------------------------------------------------------- diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/coord/zk/ZKClusterCoordinator.java b/exec/java-exec/src/main/java/org/apache/drill/exec/coord/zk/ZKClusterCoordinator.java index 8e2dbe7..83f4262 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/coord/zk/ZKClusterCoordinator.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/coord/zk/ZKClusterCoordinator.java @@ -76,6 +76,7 @@ public class ZKClusterCoordinator extends ClusterCoordinator { .connectString(connect) .build(); curator.getConnectionStateListenable().addListener(new InitialConnectionListener()); + curator.start(); discovery = getDiscovery(); serviceCache = discovery. serviceCacheBuilder() @@ -89,7 +90,6 @@ public class ZKClusterCoordinator extends ClusterCoordinator { public void start(long millisToWait) throws Exception { logger.debug("Starting ZKClusterCoordination."); - curator.start(); discovery.start(); serviceCache.start(); serviceCache.addListener(new ZKListener()); @@ -101,7 +101,6 @@ public class ZKClusterCoordinator extends ClusterCoordinator { this.initialConnection.await(); } - updateEndpoints(); }
