[pulsar] branch master updated: typo (#7281)

[hjf]

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

hjf 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 c352250  typo (#7281)
c352250 is described below

commit c3522503525379d0376ad3d1d42613abfc80e502
Author: Alexandre DUVAL <kanna...@gmail.com>
AuthorDate: Fri Jun 19 15:25:54 2020 +0200

    typo (#7281)
---
 .../main/java/org/apache/pulsar/broker/admin/impl/NamespacesBase.java   | 2 +-
 .../src/test/java/org/apache/pulsar/broker/admin/NamespacesTest.java    | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/NamespacesBase.java
 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/NamespacesBase.java
index b117c9d..d44378a 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/NamespacesBase.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/NamespacesBase.java
@@ -1466,7 +1466,7 @@ public abstract class NamespacesBase extends 
AdminResource {
     }
 
     protected void internalSetRetention(RetentionPolicies retention) {
-        validateNamespacePolicyOperation(namespaceName, 
PolicyName.REPLICATION, PolicyOperation.WRITE);
+        validateNamespacePolicyOperation(namespaceName, PolicyName.RETENTION, 
PolicyOperation.WRITE);
         validatePoliciesReadOnlyAccess();
 
         try {
diff --git 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/NamespacesTest.java
 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/NamespacesTest.java
index b018d42..366f0e8 100644
--- 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/NamespacesTest.java
+++ 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/NamespacesTest.java
@@ -180,7 +180,7 @@ public class NamespacesTest extends 
MockedPulsarServiceBaseTest {
 
         doThrow(new RestException(Status.UNAUTHORIZED, 
"unauthorized")).when(namespaces)
                 
.validateNamespacePolicyOperation(NamespaceName.get("other-tenant/use/test-namespace-1"),
-                        PolicyName.REPLICATION, PolicyOperation.WRITE);
+                        PolicyName.RETENTION, PolicyOperation.WRITE);
 
         nsSvc = pulsar.getNamespaceService();
     }