Remove duplicate check for replicationClusterSet (apache#11429)

### Motivation NamespacesBase#internalSetNamespaceReplicationClusters has duplicate codes: https://github.com/apache/pulsar/blob/a6e1a3290d9eb42f4d03438c3ce9ced506ee8445/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/NamespacesBase.java#L757-L773
lionelcao · Jul 23, 2021 · 083bb62 · 083bb62
1 parent 62b5dfb
commit 083bb62
Showing 1 changed file with 0 additions and 9 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
@@ -760,15 +760,6 @@ protected void internalSetNamespaceReplicationClusters(List<String> clusterIds)
                 throw new RestException(Status.FORBIDDEN, "Invalid cluster id: " + clusterId);
             }
             validatePeerClusterConflict(clusterId, replicationClusterSet);
-        }
-        for (String clusterId : replicationClusterSet) {
-            if (!clusters.contains(clusterId)) {
-                throw new RestException(Status.FORBIDDEN, "Invalid cluster id: " + clusterId);
-            }
-            validatePeerClusterConflict(clusterId, replicationClusterSet);
-        }
-
-        for (String clusterId : replicationClusterSet) {
             validateClusterForTenant(namespaceName.getTenant(), clusterId);
         }
         updatePolicies(path(POLICIES, namespaceName.toString()), policies ->{