[pulsar] branch master updated: fix typos in java doc and tests (#7079)

[mm...@apache.org]

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

mmerli 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 75fe26c  fix typos in java doc and tests (#7079)
75fe26c is described below

commit 75fe26c76f22efa5809c4efc4322e831a4f81928
Author: Aloys <lo...@gmail.com>
AuthorDate: Thu Jun 4 04:48:28 2020 +0800

    fix typos in java doc and tests (#7079)
    
    Co-authored-by: penghui <pe...@apache.org>
---
 .../src/main/java/org/apache/bookkeeper/mledger/impl/OpAddEntry.java   | 2 +-
 .../main/java/org/apache/pulsar/broker/service/PublishRateLimiter.java | 3 +--
 .../apache/pulsar/broker/service/persistent/MessageDeduplication.java  | 2 +-
 3 files changed, 3 insertions(+), 4 deletions(-)

diff --git a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpAddEntry.java b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpAddEntry.java
index 880685d..73d195d 100644
--- a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpAddEntry.java
+++ b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpAddEntry.java
@@ -157,7 +157,7 @@ class OpAddEntry extends SafeRunnable implements AddCallback, CloseCallback {
         }
     }
 
-    // Called in exector hashed on managed ledger name, once the add operation is complete
+    // Called in executor hashed on managed ledger name, once the add operation is complete
     @Override
     public void safeRun() {
         // Remove this entry from the head of the pending queue
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PublishRateLimiter.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PublishRateLimiter.java
index 67c7c34..090b7b9 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PublishRateLimiter.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PublishRateLimiter.java
@@ -65,8 +65,7 @@ public interface PublishRateLimiter {
 
     /**
      * updates rate-limiting threshold based on passed in rate limiter.
-     * @param policies
-     * @param clusterName
+     * @param maxPublishRate
      */
     void update(PublishRate maxPublishRate);
 
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/MessageDeduplication.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/MessageDeduplication.java
index dc4604e..5c91d52 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/MessageDeduplication.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/MessageDeduplication.java
@@ -310,7 +310,7 @@ public class MessageDeduplication {
                 }
 
                 // Also need to check sequence ids that has been persisted.
-                // If current message's seq id is smaller smaller or equals to the lastSequenceIdPersisted than its definitely a dup
+                // If current message's seq id is smaller or equals to the lastSequenceIdPersisted than its definitely a dup
                 // If current message's seq id is between lastSequenceIdPersisted and lastSequenceIdPushed, then we cannot be sure whether the message is a dup or not
                 // we should return an error to the producer for the latter case so that it can retry at a future time
                 Long lastSequenceIdPersisted = highestSequencedPersisted.get(producerName);