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 -> {

Reply via email to