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

tison 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 89b1ff10107 [fix] Some typos in Cmd classes (#19190)
89b1ff10107 is described below

commit 89b1ff1010706b647cf11a564ae2a3a5916bc715
Author: lixinyang <[email protected]>
AuthorDate: Thu Jan 12 11:56:40 2023 +0800

    [fix] Some typos in Cmd classes (#19190)
    
    Co-authored-by: nicklixinyang <[email protected]>
---
 .../main/java/org/apache/pulsar/admin/cli/CmdPackages.java |  2 +-
 .../main/java/org/apache/pulsar/admin/cli/CmdTopics.java   |  2 +-
 .../java/org/apache/pulsar/common/protocol/Commands.java   | 14 +++++++-------
 3 files changed, 9 insertions(+), 9 deletions(-)

diff --git 
a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdPackages.java
 
b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdPackages.java
index ba9e67a5b41..24214a89c57 100644
--- 
a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdPackages.java
+++ 
b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdPackages.java
@@ -100,7 +100,7 @@ class CmdPackages extends CmdBase {
         @Parameter(names = "--contact", description = "contact information of 
a package")
         private String contact;
 
-        @DynamicParameter(names = {"--properties", "-P"}, description = 
"external infromations of a package")
+        @DynamicParameter(names = {"--properties", "-P"}, description = 
"external information of a package")
         private Map<String, String> properties = new HashMap<>();
 
         @Parameter(names = "--path", description = "file path of the package", 
required = true)
diff --git 
a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTopics.java 
b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTopics.java
index 116252cca6d..874eb038e9d 100644
--- 
a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTopics.java
+++ 
b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTopics.java
@@ -1169,7 +1169,7 @@ public class CmdTopics extends CmdBase {
             Map<Integer, MessageId> messageIds = 
getTopics().terminatePartitionedTopic(persistentTopic);
             for (Map.Entry<Integer, MessageId> entry: messageIds.entrySet()) {
                 String topicName = persistentTopic + "-partition-" + 
entry.getKey();
-                System.out.println("Topic " + topicName +  " succesfully 
terminated at " + entry.getValue());
+                System.out.println("Topic " + topicName +  " successfully 
terminated at " + entry.getValue());
             }
         }
     }
diff --git 
a/pulsar-common/src/main/java/org/apache/pulsar/common/protocol/Commands.java 
b/pulsar-common/src/main/java/org/apache/pulsar/common/protocol/Commands.java
index 4d4d64f7fe9..081dfe4275b 100644
--- 
a/pulsar-common/src/main/java/org/apache/pulsar/common/protocol/Commands.java
+++ 
b/pulsar-common/src/main/java/org/apache/pulsar/common/protocol/Commands.java
@@ -499,25 +499,25 @@ public class Commands {
                         DEFAULT_CONSUMER_EPOCH), metadataAndPayload);
     }
 
-    public static ByteBufPair newSend(long producerId, long sequenceId, int 
numMessaegs, ChecksumType checksumType,
+    public static ByteBufPair newSend(long producerId, long sequenceId, int 
numMessages, ChecksumType checksumType,
                                       long ledgerId, long entryId, 
MessageMetadata messageMetadata, ByteBuf payload) {
-        return newSend(producerId, sequenceId, -1 /* highestSequenceId */, 
numMessaegs,
+        return newSend(producerId, sequenceId, -1 /* highestSequenceId */, 
numMessages,
                 messageMetadata.hasTxnidLeastBits() ? 
messageMetadata.getTxnidLeastBits() : -1,
                 messageMetadata.hasTxnidMostBits() ? 
messageMetadata.getTxnidMostBits() : -1,
                 checksumType, ledgerId, entryId, messageMetadata, payload);
     }
 
-    public static ByteBufPair newSend(long producerId, long sequenceId, int 
numMessaegs, ChecksumType checksumType,
+    public static ByteBufPair newSend(long producerId, long sequenceId, int 
numMessages, ChecksumType checksumType,
                                       MessageMetadata messageMetadata, ByteBuf 
payload) {
-        return newSend(producerId, sequenceId, -1 /* highestSequenceId */, 
numMessaegs,
+        return newSend(producerId, sequenceId, -1 /* highestSequenceId */, 
numMessages,
                 messageMetadata.hasTxnidLeastBits() ? 
messageMetadata.getTxnidLeastBits() : -1,
                 messageMetadata.hasTxnidMostBits() ? 
messageMetadata.getTxnidMostBits() : -1,
                 checksumType, -1, -1, messageMetadata, payload);
     }
 
-    public static ByteBufPair newSend(long producerId, long lowestSequenceId, 
long highestSequenceId, int numMessaegs,
+    public static ByteBufPair newSend(long producerId, long lowestSequenceId, 
long highestSequenceId, int numMessages,
               ChecksumType checksumType, MessageMetadata messageMetadata, 
ByteBuf payload) {
-        return newSend(producerId, lowestSequenceId, highestSequenceId, 
numMessaegs,
+        return newSend(producerId, lowestSequenceId, highestSequenceId, 
numMessages,
                 messageMetadata.hasTxnidLeastBits() ? 
messageMetadata.getTxnidLeastBits() : -1,
                 messageMetadata.hasTxnidMostBits() ? 
messageMetadata.getTxnidMostBits() : -1,
                 checksumType, -1, -1, messageMetadata, payload);
@@ -1993,7 +1993,7 @@ public class Commands {
         case ExclusiveWithFencing:
             return ProducerAccessMode.ExclusiveWithFencing;
         default:
-            throw new IllegalArgumentException("Unknonw access mode: " + 
accessMode);
+            throw new IllegalArgumentException("Unknown access mode: " + 
accessMode);
         }
     }
 

Reply via email to