big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

YARN-10957. Using invokeConcurrent Overload with Collection in getClusterMetrics (#3439)

Browse Source
This commit is contained in:
Akshat Bordia 2021-09-28 22:21:18 +05:30 committed by GitHub
parent f5148ca542
commit 51bd528bd3
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-router/src/main/java/org/apache/hadoop/yarn/server/router/clientrm/FederationClientInterceptor.java
View File

@ -664,11 +664,10 @@ public GetClusterMetricsResponse getClusterMetrics(
federationFacade.getSubClusters(true); federationFacade.getSubClusters(true);
ClientMethod remoteMethod = new ClientMethod("getClusterMetrics", ClientMethod remoteMethod = new ClientMethod("getClusterMetrics",
new Class[] {GetClusterMetricsRequest.class}, new Object[] {request}); new Class[] {GetClusterMetricsRequest.class}, new Object[] {request});
ArrayList<SubClusterId> clusterList = new ArrayList<>(subclusters.keySet());
Map<SubClusterId, GetClusterMetricsResponse> clusterMetrics; Map<SubClusterId, GetClusterMetricsResponse> clusterMetrics;
try { try {
clusterMetrics = invokeConcurrent(clusterList, remoteMethod, clusterMetrics = invokeConcurrent(subclusters.keySet(), remoteMethod,
GetClusterMetricsResponse.class); GetClusterMetricsResponse.class);
} catch (Exception ex) { } catch (Exception ex) {