From 230543a0c251ee536872460d10471ef2dadf887a Mon Sep 17 00:00:00 2001 From: horsteff Date: Tue, 19 May 2020 17:58:06 +0200 Subject: [PATCH] [Issue 6921][pulsar-broker-common] Replaced "Paths.get(...).getParent()", because it's system dependent and uses '\' as path separator on Windows --- .../apache/pulsar/broker/cache/ConfigurationCacheService.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/cache/ConfigurationCacheService.java b/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/cache/ConfigurationCacheService.java index 3c3c27abe766d..6fda6cd6a5843 100644 --- a/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/cache/ConfigurationCacheService.java +++ b/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/cache/ConfigurationCacheService.java @@ -18,7 +18,6 @@ */ package org.apache.pulsar.broker.cache; -import java.nio.file.Paths; import java.util.Map; import org.apache.bookkeeper.util.ZkUtils; @@ -127,7 +126,8 @@ public FailureDomain deserialize(String path, byte[] content) throws Exception { private void createFailureDomainRoot(ZooKeeper zk, String path) { try { - final String clusterZnodePath = Paths.get(path).getParent().toString(); + final int index = path.lastIndexOf('/'); + final String clusterZnodePath = (index > 0) ? path.substring(0, index) : null; if (zk.exists(clusterZnodePath, false) != null && zk.exists(path, false) == null) { try { byte[] data = "".getBytes();