ayushtkn commented on a change in pull request #3745:
URL: https://github.com/apache/hadoop/pull/3745#discussion_r761645296
##########
File path:
hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RouterRpcServer.java
##########
@@ -716,26 +718,23 @@ static String getMethodName() {
if (nss.isEmpty()) {
throw ioe;
}
- String nsId = nss.iterator().next().getNameserviceId();
- return rpcClient.invokeSingle(nsId, method, clazz);
- }
-
- /**
- * Get set of namespace info's removing the already invoked namespaceinfo.
- * @param nss List of namespaces in the federation.
- * @param nsId Already invoked namespace id.
- * @return List of name spaces in the federation on
- * removing the already invoked namespaceinfo.
- */
- private static Set<FederationNamespaceInfo> getNameSpaceInfo(
- final Set<FederationNamespaceInfo> nss, final String nsId) {
- Set<FederationNamespaceInfo> namespaceInfos = new HashSet<>();
- for (FederationNamespaceInfo ns : nss) {
- if (!nsId.equals(ns.getNameserviceId())) {
- namespaceInfos.add(ns);
+ for (Iterator<FederationNamespaceInfo> it = nss.iterator(); it
Review comment:
Done
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
