commit bf34bb0de2b8ada63c9d83784744971da741295d
author Tboy <technoboy@apache.org> Fri Apr 02 02:39:43 2021 +0800
committer GitHub <noreply@github.com> Thu Apr 01 11:39:43 2021 -0700
tree da84079f8454030fef8ddb8891ace80295110f02
parent 6717974eda5192666c7769efc87c80ecff381ce1

Fix 'Global' cluster will create in standalone mode. #10067 (#10068)

Fix #10067 .

pulsar-broker/src/main/java/org/apache/pulsar/PulsarStandalone.java

diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/PulsarStandalone.java b/pulsar-broker/src/main/java/org/apache/pulsar/PulsarStandalone.java
index 51adb8e..43e4c24 100644
--- 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 @@
             }
 
             // 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));
             }