diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/test/java/org/apache/hadoop/yarn/client/api/impl/TestAMRMClientOnRMRestart.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/test/java/org/apache/hadoop/yarn/client/api/impl/TestAMRMClientOnRMRestart.java index fa3c6afeb36..337d7d4af70 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/test/java/org/apache/hadoop/yarn/client/api/impl/TestAMRMClientOnRMRestart.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/test/java/org/apache/hadoop/yarn/client/api/impl/TestAMRMClientOnRMRestart.java @@ -29,7 +29,6 @@ import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.CommonConfigurationKeys; import org.apache.hadoop.net.NetworkTopology; -import org.apache.hadoop.net.ServerSocketUtil; import org.apache.hadoop.security.SecurityUtil; import org.apache.hadoop.security.UserGroupInformation; import org.apache.hadoop.security.token.SecretManager.InvalidToken; @@ -93,6 +92,7 @@ public static void setup() throws Exception { YarnConfiguration.DEFAULT_RM_AM_MAX_ATTEMPTS); conf.setBoolean(YarnConfiguration.RM_WORK_PRESERVING_RECOVERY_ENABLED, true); conf.setLong(YarnConfiguration.RM_WORK_PRESERVING_RECOVERY_SCHEDULING_WAIT_MS, 0); + conf.set(YarnConfiguration.RM_SCHEDULER_ADDRESS, "0.0.0.0:0"); } @AfterClass @@ -496,8 +496,6 @@ public void testAMRMClientOnAMRMTokenRollOverOnRMRestart() throws Exception { .getMasterKey().getKeyId() == newToken.decodeIdentifier().getKeyId()); // start 2nd RM - conf.set(YarnConfiguration.RM_SCHEDULER_ADDRESS, "0.0.0.0:" - + ServerSocketUtil.getPort(45020, 10)); final MyResourceManager2 rm2 = new MyResourceManager2(conf, memStore); rm2.start(); nm1.setResourceTrackerService(rm2.getResourceTrackerService());