diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/client/RMProxy.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/client/RMProxy.java index 5b04f074c5e91..4b4d61ed6c201 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/client/RMProxy.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/client/RMProxy.java @@ -130,8 +130,11 @@ protected static T createRMProxy(final Configuration configuration, protected static T createRMProxyFederation(final Configuration configuration, final Class protocol, RMProxy instance) throws IOException { YarnConfiguration yarnConf = new YarnConfiguration(configuration); - RetryPolicy retryPolicy = createRetryPolicy(yarnConf, isFailoverEnabled(yarnConf)); - return newProxyInstanceFederation(yarnConf, protocol, instance, retryPolicy); + if (isFederationNonHAEnabled(yarnConf)) { + RetryPolicy retryPolicy = createRetryPolicy(yarnConf, isFailoverEnabled(yarnConf)); + return newProxyInstanceFederation(yarnConf, protocol, instance, retryPolicy); + } + return createRMProxy(configuration, protocol, instance); } protected static T newProxyInstanceFederation(final YarnConfiguration conf,