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);
}
}