[kylin] branch realtime-streaming updated: KYLIN-3768 Save streaming metadata a standard kylin path in zookeeper

[magang]

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

magang pushed a commit to branch realtime-streaming
in repository https://gitbox.apache.org/repos/asf/kylin.git


The following commit(s) were added to refs/heads/realtime-streaming by this 
push:
     new 5b85ebe  KYLIN-3768 Save streaming metadata a standard kylin path in 
zookeeper
5b85ebe is described below

commit 5b85ebe7826311b51ee6cb2903c788af533808dc
Author: Ma,Gang <ga...@ebay.com>
AuthorDate: Wed Jan 23 15:08:27 2019 +0800

    KYLIN-3768 Save streaming metadata a standard kylin path in zookeeper
---
 .../src/main/java/org/apache/kylin/stream/coordinator/ZKUtils.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/stream-coordinator/src/main/java/org/apache/kylin/stream/coordinator/ZKUtils.java
 
b/stream-coordinator/src/main/java/org/apache/kylin/stream/coordinator/ZKUtils.java
index 6f08b44..b7e720d 100644
--- 
a/stream-coordinator/src/main/java/org/apache/kylin/stream/coordinator/ZKUtils.java
+++ 
b/stream-coordinator/src/main/java/org/apache/kylin/stream/coordinator/ZKUtils.java
@@ -37,7 +37,7 @@ import com.google.common.base.Function;
 import com.google.common.collect.Iterables;
 
 public class ZKUtils {
-    public static final String ZK_ROOT = "/kylin/stream/" + 
KylinConfig.getInstanceFromEnv().getDeployEnv();
+    public static final String ZK_ROOT = 
KylinConfig.getInstanceFromEnv().getZookeeperBasePath() + "/stream/" + 
KylinConfig.getInstanceFromEnv().getDeployEnv();
     public static final String COORDINATOR_LEAD = ZK_ROOT + "/coordinator";
     public static final String REPLICASETS_LEADER_ELECT = ZK_ROOT + 
"/replica_sets_lead";
     private static final Logger logger = 
LoggerFactory.getLogger(ZKUtils.class);