[Improvement] fix string comparison in ZkClusterInitializer (#4451)

apache · Jun 26, 2024 · 7594705 · 7594705
1 parent e200aa3
commit 7594705
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...src/main/java/org/apache/bookkeeper/stream/storage/impl/cluster/ZkClusterInitializer.java b/...src/main/java/org/apache/bookkeeper/stream/storage/impl/cluster/ZkClusterInitializer.java
@@ -77,7 +77,7 @@ public boolean initializeCluster(URI metadataServiceUri, int numStorageContainer
 
                     String ledgersPath = metadataServiceUri.getPath();
                     Optional<String> segmentStorePath;
-                    if (Strings.isNullOrEmpty(ledgersPath) || "/" == ledgersPath) {
+                    if (Strings.isNullOrEmpty(ledgersPath) || "/".equals(ledgersPath)) {
                         segmentStorePath = Optional.empty();
                     } else {
                         segmentStorePath = Optional.of(ledgersPath);