You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by te...@apache.org on 2025/09/18 02:17:21 UTC
(pulsar) branch master updated: [fix][broker] Fix typos in PulsarClusterMetadataSetup (#24750)
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 <11...@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);
}
}