From 5f0b787b63bfea8a738cf8fb311ad51a05a8675c Mon Sep 17 00:00:00 2001
From: lipenghui <penghui@apache.org>
Date: Fri, 2 Jul 2021 18:13:04 +0800
Subject: [PATCH] Fix some typos of the PersistentTopics (#11187)

(cherry picked from commit 5855e0c87f3a3ee67e21db6957910092da348b8c)
---
 .../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 32ec02d2f7e80..20e3f75fd8eb5 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 void deleteMaxUnackedMessagesOnSubscription(@Suspended final AsyncRespons
             @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 void removeDeduplication(@Suspended final AsyncResponse asyncResponse,
             .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 void removeRetention(@Suspended final AsyncResponse asyncResponse,
                 asyncResponse.resume(Response.noContent().build());
             })
             .exceptionally(ex -> {
-                handleTopicPolicyException("setRetention", ex, asyncResponse);
+                handleTopicPolicyException("removeRetention", ex, asyncResponse);
                 return null;
             });
     }