diff --git a/apm-collector/apm-collector-cluster/collector-cluster-zookeeper-provider/src/main/java/org/apache/skywalking/apm/collector/cluster/zookeeper/ClusterZKDataMonitor.java b/apm-collector/apm-collector-cluster/collector-cluster-zookeeper-provider/src/main/java/org/apache/skywalking/apm/collector/cluster/zookeeper/ClusterZKDataMonitor.java index eb51be648d46ce090e26c731600402a6a5972049..4def6a81b79c16e08a2d6e40483edc2382b9e787 100644 --- a/apm-collector/apm-collector-cluster/collector-cluster-zookeeper-provider/src/main/java/org/apache/skywalking/apm/collector/cluster/zookeeper/ClusterZKDataMonitor.java +++ b/apm-collector/apm-collector-cluster/collector-cluster-zookeeper-provider/src/main/java/org/apache/skywalking/apm/collector/cluster/zookeeper/ClusterZKDataMonitor.java @@ -34,6 +34,7 @@ import org.apache.skywalking.apm.collector.cluster.DataMonitor; import org.apache.skywalking.apm.collector.cluster.ModuleRegistration; import org.apache.skywalking.apm.collector.core.CollectorException; import org.apache.skywalking.apm.collector.core.util.CollectionUtils; +import org.apache.skywalking.apm.util.StringUtil; import org.apache.zookeeper.CreateMode; import org.apache.zookeeper.WatchedEvent; import org.apache.zookeeper.Watcher; @@ -165,7 +166,11 @@ public class ClusterZKDataMonitor implements DataMonitor, Watcher { } @Override public String getBaseCatalog() { - return "/" + namespace + "/skywalking"; + if (StringUtil.isEmpty(namespace)) { + return "/skywalking"; + } else { + return "/" + namespace + "/skywalking"; + } } void setNamespace(String namespace) {