From 5011e125f8d35a8cd69b736b61f7dacd0840bc45 Mon Sep 17 00:00:00 2001 From: slfan1989 Date: Tue, 29 Nov 2022 23:27:31 +0800 Subject: [PATCH] YARN-11226. Fix CheckStyle. --- .../org/apache/hadoop/yarn/server/router/RouterServerUtil.java | 2 -- .../yarn/server/router/webapp/FederationInterceptorREST.java | 2 +- 2 files changed, 1 insertion(+), 3 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/RouterServerUtil.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-router/src/main/java/org/apache/hadoop/yarn/server/router/RouterServerUtil.java index c49d9062579de..e02b5e35c0166 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-router/src/main/java/org/apache/hadoop/yarn/server/router/RouterServerUtil.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-router/src/main/java/org/apache/hadoop/yarn/server/router/RouterServerUtil.java @@ -42,8 +42,6 @@ import org.apache.hadoop.yarn.server.federation.utils.FederationStateStoreFacade; import org.apache.hadoop.yarn.exceptions.YarnException; import org.apache.hadoop.yarn.exceptions.YarnRuntimeException; -import org.apache.hadoop.yarn.server.federation.policies.FederationPolicyUtils; -import org.apache.hadoop.yarn.server.federation.store.records.SubClusterInfo; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-router/src/main/java/org/apache/hadoop/yarn/server/router/webapp/FederationInterceptorREST.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-router/src/main/java/org/apache/hadoop/yarn/server/router/webapp/FederationInterceptorREST.java index 36f9d98cd7899..04050c059b9fd 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-router/src/main/java/org/apache/hadoop/yarn/server/router/webapp/FederationInterceptorREST.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-router/src/main/java/org/apache/hadoop/yarn/server/router/webapp/FederationInterceptorREST.java @@ -1601,7 +1601,7 @@ public Response createNewReservation(HttpServletRequest hsr) for (int i = 0; i < numSubmitRetries; ++i) { SubClusterId subClusterId = null; try { - subClusterId = getRandomActiveSubCluster(subClustersActive, blacklist); + subClusterId = federationFacade.getRandomActiveSubCluster(subClustersActive, blacklist); SubClusterInfo subClusterInfo = subClustersActive.get(subClusterId); DefaultRequestInterceptorREST interceptor = getOrCreateInterceptorForSubCluster( subClusterId, subClusterInfo.getRMWebServiceAddress());