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