commit | 51bd528bd34b6c01d9d1126ffed2fc6cb94604c2 | [log] [tgz] |
---|---|---|
author | Akshat Bordia <31816865+akshatb1@users.noreply.github.com> | Tue Sep 28 22:21:18 2021 +0530 |
committer | GitHub <noreply@github.com> | Tue Sep 28 09:51:18 2021 -0700 |
tree | fa030a9e68f540e5b3e241711745bf1712af8d93 | |
parent | f5148ca542108d1e308a89922d765119bfa73ab4 [diff] |
YARN-10957. Using invokeConcurrent Overload with Collection in getClusterMetrics (#3439)
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-router/src/main/java/org/apache/hadoop/yarn/server/router/clientrm/FederationClientInterceptor.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-router/src/main/java/org/apache/hadoop/yarn/server/router/clientrm/FederationClientInterceptor.java index 391bc1c..3133ad5 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-router/src/main/java/org/apache/hadoop/yarn/server/router/clientrm/FederationClientInterceptor.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-router/src/main/java/org/apache/hadoop/yarn/server/router/clientrm/FederationClientInterceptor.java
@@ -664,11 +664,10 @@ federationFacade.getSubClusters(true); ClientMethod remoteMethod = new ClientMethod("getClusterMetrics", new Class[] {GetClusterMetricsRequest.class}, new Object[] {request}); - ArrayList<SubClusterId> clusterList = new ArrayList<>(subclusters.keySet()); Map<SubClusterId, GetClusterMetricsResponse> clusterMetrics; try { - clusterMetrics = invokeConcurrent(clusterList, remoteMethod, + clusterMetrics = invokeConcurrent(subclusters.keySet(), remoteMethod, GetClusterMetricsResponse.class); } catch (Exception ex) {