(pulsar) branch master updated: [fix][broker] Fix typos in PulsarClusterMetadataSetup (#24750)

[technoboy]

This is an automated email from the ASF dual-hosted git repository.

technoboy pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 5baaabc1047 [fix][broker] Fix typos in PulsarClusterMetadataSetup 
(#24750)
5baaabc1047 is described below

commit 5baaabc1047f09a4676aba40e41e8028a0ed061f
Author: Wonyong Hwang <111210881+wonyo...@users.noreply.github.com>
AuthorDate: Thu Sep 18 11:17:15 2025 +0900

    [fix][broker] Fix typos in PulsarClusterMetadataSetup (#24750)
---
 .../java/org/apache/pulsar/PulsarClusterMetadataSetup.java     | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/PulsarClusterMetadataSetup.java 
b/pulsar-broker/src/main/java/org/apache/pulsar/PulsarClusterMetadataSetup.java
index 267e4f7eac7..ce3bffe63d9 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/PulsarClusterMetadataSetup.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/PulsarClusterMetadataSetup.java
@@ -192,7 +192,7 @@ public class PulsarClusterMetadataSetup {
     }
 
     /**
-     * a wrapper for creating a persistent node with store.put but ignore 
exception of node exists.
+     * A wrapper for creating a persistent node using store.put(), ignoring 
the exception if the node already exists.
      */
     private static void createMetadataNode(MetadataStore store, String path, 
byte[] data)
             throws InterruptedException, ExecutionException {
@@ -282,7 +282,7 @@ public class PulsarClusterMetadataSetup {
         try {
             initializeCluster(arguments, bundleNumberForDefaultNamespace);
         } catch (Exception e) {
-            System.err.println("Unexpected error occured.");
+            System.err.println("Unexpected error occurred.");
             e.printStackTrace(System.err);
             System.err.println("Terminating JVM...");
             ShutdownUtil.triggerImmediateForcefulShutdown();
@@ -300,7 +300,7 @@ public class PulsarClusterMetadataSetup {
                 arguments.configurationStoreConfigPath,
                 arguments.zkSessionTimeoutMillis);
 
-        final String metadataStoreUrlNoIdentifer = MetadataStoreFactoryImpl
+        final String metadataStoreUrlNoIdentifier = MetadataStoreFactoryImpl
                 .removeIdentifierFromMetadataURL(arguments.metadataStoreUrl);
         // Format BookKeeper ledger storage metadata
         if (arguments.existingBkMetadataServiceUri == null && 
arguments.bookieMetadataServiceUri == null) {
@@ -322,7 +322,7 @@ public class PulsarClusterMetadataSetup {
             } else if (arguments.bookieMetadataServiceUri != null) {
                 uriStr = arguments.bookieMetadataServiceUri;
             } else {
-                uriStr = "zk+null://" + metadataStoreUrlNoIdentifer + 
BookKeeperConstants.DEFAULT_ZK_LEDGERS_ROOT_PATH;
+                uriStr = "zk+null://" + metadataStoreUrlNoIdentifier + 
BookKeeperConstants.DEFAULT_ZK_LEDGERS_ROOT_PATH;
             }
 
             // initial distributed log metadata
@@ -331,7 +331,7 @@ public class PulsarClusterMetadataSetup {
             ServiceURI bkMetadataServiceUri = ServiceURI.create(uriStr);
             // Format BookKeeper stream storage metadata
             if (arguments.numStreamStorageContainers > 0) {
-                ClusterInitializer initializer = new 
ZkClusterInitializer(metadataStoreUrlNoIdentifer);
+                ClusterInitializer initializer = new 
ZkClusterInitializer(metadataStoreUrlNoIdentifier);
                 initializer.initializeCluster(bkMetadataServiceUri.getUri(), 
arguments.numStreamStorageContainers);
             }
         }