You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by ma...@apache.org on 2019/01/23 07:08:45 UTC

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

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);