This is an automated email from the ASF dual-hosted git repository.
shoothzj 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 b17982d Fix some typos (#13715)
b17982d is described below
commit b17982d81e63336ce4696537fa1e6ba6cfaa9d7f
Author: Prashant Kumar <[email protected]>
AuthorDate: Sun Feb 27 21:00:26 2022 -0800
Fix some typos (#13715)
**Motivation**
Fix some typos.
Co-authored-by: Prashant Kumar <[email protected]>
Co-authored-by: ZhangJian He <[email protected]>
---
.../java/org/apache/pulsar/broker/namespace/OwnershipCache.java | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
diff --git
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/OwnershipCache.java
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/OwnershipCache.java
index ea85406..382a3cc 100644
---
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/OwnershipCache.java
+++
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/OwnershipCache.java
@@ -177,7 +177,8 @@ public class OwnershipCache {
}
/**
- * Method to get the current owner of the <code>ServiceUnit</code> or set
the local broker as the owner if absent.
+ * Method to get the current owner of the <code>NamespaceBundle</code>
+ * or set the local broker as the owner if absent.
*
* @param bundle
* the <code>NamespaceBundle</code>
@@ -187,12 +188,12 @@ public class OwnershipCache {
public CompletableFuture<NamespaceEphemeralData>
tryAcquiringOwnership(NamespaceBundle bundle) throws Exception {
if (!refreshSelfOwnerInfo()) {
return FutureUtil.failedFuture(
- new RuntimeException("Namespace service does not ready for
acquiring ownership"));
+ new RuntimeException("Namespace service is not ready for
acquiring ownership"));
}
LOG.info("Trying to acquire ownership of {}", bundle);
- // Doing a get() on the ownedBundlesCache will trigger an async
metatada write to acquire the lock over the
+ // Doing a get() on the ownedBundlesCache will trigger an async
metadata write to acquire the lock over the
// service unit
return ownedBundlesCache.get(bundle)
.thenApply(namespaceBundle -> {