[pulsar] 04/06: Fix some typos of the PersistentTopics (#11187)

[penghui]

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

penghui pushed a commit to branch branch-2.8
in repository https://gitbox.apache.org/repos/asf/pulsar.git

commit 5f0b787b63bfea8a738cf8fb311ad51a05a8675c
Author: lipenghui <peng...@apache.org>
AuthorDate: Fri Jul 2 18:13:04 2021 +0800

    Fix some typos of the PersistentTopics (#11187)
    
    
    (cherry picked from commit 5855e0c87f3a3ee67e21db6957910092da348b8c)
---
 .../java/org/apache/pulsar/broker/admin/v2/PersistentTopics.java     | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/PersistentTopics.java
 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/PersistentTopics.java
index 32ec02d..20e3f75 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/PersistentTopics.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/PersistentTopics.java
@@ -600,7 +600,6 @@ public class PersistentTopics extends PersistentTopicsBase {
             @ApiParam(value = "Is authentication required to perform this 
operation")
             @QueryParam("authoritative") @DefaultValue("false") boolean 
authoritative) {
         validateTopicName(tenant, namespace, encodedTopic);
-        validateTopicName(tenant, namespace, encodedTopic);
         validateTopicPolicyOperation(topicName, PolicyName.MAX_UNACKED, 
PolicyOperation.WRITE);
         preValidation(authoritative)
             .thenCompose(__ -> 
internalSetMaxUnackedMessagesOnSubscription(null))
@@ -1767,7 +1766,7 @@ public class PersistentTopics extends 
PersistentTopicsBase {
             .thenCompose(__ -> internalSetDeduplication(null))
             .thenRun(() -> asyncResponse.resume(Response.noContent().build()))
             .exceptionally(ex -> {
-                handleTopicPolicyException("setDeduplication", ex, 
asyncResponse);
+                handleTopicPolicyException("removeDeduplication", ex, 
asyncResponse);
                 return null;
             });
     }
@@ -1858,7 +1857,7 @@ public class PersistentTopics extends 
PersistentTopicsBase {
                 asyncResponse.resume(Response.noContent().build());
             })
             .exceptionally(ex -> {
-                handleTopicPolicyException("setRetention", ex, asyncResponse);
+                handleTopicPolicyException("removeRetention", ex, 
asyncResponse);
                 return null;
             });
     }