From 51bd528bd34b6c01d9d1126ffed2fc6cb94604c2 Mon Sep 17 00:00:00 2001
From: Akshat Bordia <31816865+akshatb1@users.noreply.github.com>
Date: Tue, 28 Sep 2021 22:21:18 +0530
Subject: [PATCH] YARN-10957. Using invokeConcurrent Overload with Collection
 in getClusterMetrics (#3439)

---
 .../server/router/clientrm/FederationClientInterceptor.java    | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

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 391bc1ca98f..3133ad5ceda 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 @@ public class FederationClientInterceptor
         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) {