You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by in...@apache.org on 2021/09/28 16:54:39 UTC
[hadoop] branch trunk updated: YARN-10957. Using invokeConcurrent
Overload with Collection in getClusterMetrics (#3439)
This is an automated email from the ASF dual-hosted git repository.
inigoiri pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/trunk by this push:
new 51bd528 YARN-10957. Using invokeConcurrent Overload with Collection in getClusterMetrics (#3439)
51bd528 is described below
commit 51bd528bd34b6c01d9d1126ffed2fc6cb94604c2
Author: Akshat Bordia <31...@users.noreply.github.com>
AuthorDate: Tue Sep 28 22:21:18 2021 +0530
YARN-10957. Using invokeConcurrent Overload with Collection in getClusterMetrics (#3439)
---
.../yarn/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 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 @@ 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) {
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org