This is an automated email from the ASF dual-hosted git repository.
zixuan 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 a8e629635b7 [fix] Fix typo 'seperated' in broker comments (#25524)
a8e629635b7 is described below
commit a8e629635b740341489f65ccdf75e837a709cf70
Author: Mukunda Rao Katta <[email protected]>
AuthorDate: Wed Apr 15 02:51:05 2026 -0700
[fix] Fix typo 'seperated' in broker comments (#25524)
Co-authored-by: MukundaKatta <[email protected]>
---
.../org/apache/pulsar/broker/service/persistent/PersistentTopic.java | 4 ++--
.../pulsar/broker/admin/GetPartitionMetadataMultiBrokerTest.java | 4 ++--
.../java/org/apache/pulsar/broker/service/ZkSessionExpireTest.java | 2 +-
3 files changed, 5 insertions(+), 5 deletions(-)
diff --git
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
index 377cbcca8b8..6ef376b58a2 100644
---
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
+++
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
@@ -344,7 +344,7 @@ public class PersistentTopic extends AbstractTopic
implements Topic, AddEntryCal
* 2. Namespace bundle transfer or unloading.
* a. The unloading topic triggered by unloading namespace bundles will
not wait for clients disconnect. Relate
* to {@link CloseFutures#notWaitDisconnectClients}.
- * b. The unloading topic triggered by unloading namespace bundles was
seperated to two steps when using
+ * b. The unloading topic triggered by unloading namespace bundles was
separated into two steps when using
* {@link ExtensibleLoadManagerImpl}.
* b-1. step-1: fence the topic on the original Broker, and do not
trigger reconnections of clients. Relate
* to {@link CloseFutures#transferring}. This step is a half closing.
@@ -3425,7 +3425,7 @@ public class PersistentTopic extends AbstractTopic
implements Topic, AddEntryCal
* "replicator.producer" to a null value.
* Race condition: task 1 will get a NPE when it tries to send
messages using the variable
* "replicator.producer", because task 2 will set this variable to
"null".
- * TODO Create a seperated PR to fix it.
+ * TODO Create a separate PR to fix it.
*/
closeReplProducersIfNoBacklog().thenRun(() -> {
if (hasRemoteProducers()) {
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/GetPartitionMetadataMultiBrokerTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/GetPartitionMetadataMultiBrokerTest.java
index 1b4732f69d4..b6a3cf15625 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/GetPartitionMetadataMultiBrokerTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/GetPartitionMetadataMultiBrokerTest.java
@@ -135,7 +135,7 @@ public class GetPartitionMetadataMultiBrokerTest extends
GetPartitionMetadataTes
} catch (Exception ex) {
// If the namespace bundle has not been loaded yet, it means no
non-persistent topic was created. So
// this behavior is also correct.
- // This error is not expected, a seperated PR is needed to fix
this issue.
+ // This error is not expected, a separate PR is needed to fix this
issue.
assertTrue(ex.getMessage().contains("Failed to find ownership
for"));
}
}
@@ -148,7 +148,7 @@ public class GetPartitionMetadataMultiBrokerTest extends
GetPartitionMetadataTes
} catch (Exception ex) {
// If the namespace bundle has not been loaded yet, it means no
non-persistent topic was created. So
// this behavior is also correct.
- // This error is not expected, a seperated PR is needed to fix
this issue.
+ // This error is not expected, a separate PR is needed to fix this
issue.
assertTrue(ex.getMessage().contains("Failed to find ownership
for"));
}
}
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ZkSessionExpireTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ZkSessionExpireTest.java
index e19fd09d062..c83b6114035 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ZkSessionExpireTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ZkSessionExpireTest.java
@@ -256,7 +256,7 @@ public class ZkSessionExpireTest extends
NetworkErrorTestBase {
// Regarding the system topic based load balancer, which does not
rely on ZK, the topic may be owned by any
// broker.
if (TableViewType.SystemTopic.equals(tableViewType)) {
- // This implementation will be finished by a seperated PR.
+ // This implementation will be finished by a separate PR.
}
});
Topic broker2Topic3 = pulsar2.getBrokerService().getTopic(topicName,
false).join().get();