You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@drill.apache.org by ja...@apache.org on 2014/06/11 05:52:20 UTC
[35/61] [abbrv] git commit: Curator needs to be started before
ServiceCache can be built.
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 <ad...@maprtech.com>
Authored: Sat Jun 7 13:50:18 2014 -0700
Committer: Jacques Nadeau <ja...@apache.org>
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();
}