(pulsar) branch master updated: [fix][cli] Fix typos in CmdSinks class (#22358)

[technoboy]

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

technoboy 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 023446b7328 [fix][cli] Fix typos in CmdSinks class (#22358)
023446b7328 is described below

commit 023446b73287dea25c22c6db307e5d723306e765
Author: hanmz <gunn...@tencent.com>
AuthorDate: Wed Mar 27 11:40:28 2024 +0800

    [fix][cli] Fix typos in CmdSinks class (#22358)
---
 .../src/main/java/org/apache/pulsar/admin/cli/CmdSinks.java           | 2 +-
 .../src/test/java/org/apache/pulsar/admin/cli/TestCmdSinks.java       | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSinks.java 
b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSinks.java
index 47af7e6794c..f3172a49b01 100644
--- 
a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSinks.java
+++ 
b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSinks.java
@@ -617,7 +617,7 @@ public class CmdSinks extends CmdBase {
         protected void validateSinkConfigs(SinkConfig sinkConfig) {
 
             if (isBlank(sinkConfig.getArchive())) {
-                throw new ParameterException("Sink archive not specfied");
+                throw new ParameterException("Sink archive not specified");
             }
 
             
org.apache.pulsar.common.functions.Utils.inferMissingArguments(sinkConfig);
diff --git 
a/pulsar-client-tools/src/test/java/org/apache/pulsar/admin/cli/TestCmdSinks.java
 
b/pulsar-client-tools/src/test/java/org/apache/pulsar/admin/cli/TestCmdSinks.java
index c68bbd20ab8..6fbe3bc5da2 100644
--- 
a/pulsar-client-tools/src/test/java/org/apache/pulsar/admin/cli/TestCmdSinks.java
+++ 
b/pulsar-client-tools/src/test/java/org/apache/pulsar/admin/cli/TestCmdSinks.java
@@ -283,7 +283,7 @@ public class TestCmdSinks {
     }
 
     @Test(expectedExceptions = CliCommand.ParameterException.class,
-            expectedExceptionsMessageRegExp = "Sink archive not specfied")
+            expectedExceptionsMessageRegExp = "Sink archive not specified")
     public void testMissingArchive() throws Exception {
         SinkConfig sinkConfig = getSinkConfig();
         sinkConfig.setArchive(null);
@@ -503,7 +503,7 @@ public class TestCmdSinks {
         testCmdSinkConfigFile(testSinkConfig, expectedSinkConfig);
     }
 
-    @Test(expectedExceptions = CliCommand.ParameterException.class, 
expectedExceptionsMessageRegExp = "Sink archive not specfied")
+    @Test(expectedExceptions = CliCommand.ParameterException.class, 
expectedExceptionsMessageRegExp = "Sink archive not specified")
     public void testCmdSinkConfigFileMissingJar() throws Exception {
         SinkConfig testSinkConfig = getSinkConfig();
         testSinkConfig.setArchive(null);