Fix some typos of the PersistentTopics (#11187)

(cherry picked from commit 5855e0c)
apache · Jul 7, 2021 · 5f0b787 · 5f0b787
1 parent ef7a46d
commit 5f0b787
Showing 1 changed file with 2 additions and 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
@@ -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;
             });
     }