Fix 'Global' cluster will create in standalone mode. apache#10067 (ap…

…ache#10068) Fix apache#10067 .
teazj · Apr 1, 2021 · bf34bb0 · bf34bb0
1 parent 6717974
commit bf34bb0
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/PulsarStandalone.java b/pulsar-broker/src/main/java/org/apache/pulsar/PulsarStandalone.java
@@ -375,7 +375,9 @@ private void createSampleNameSpace(ClusterData clusterData, String cluster) {
             }
 
             // Create marker for "global" cluster
-            if (!admin.clusters().getClusters().contains(globalCluster)) {
+            try {
+                admin.clusters().getCluster(globalCluster);
+            } catch (PulsarAdminException.NotFoundException ex) {
                 admin.clusters().createCluster(globalCluster, new ClusterData(null, null));
             }