.../apache/hadoop/yarn/client/api/impl/TestAMRMClientOnRMRestart.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) 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 2394747..65c85d9 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 @@ -27,6 +27,7 @@ import org.apache.hadoop.conf.Configuration; 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; @@ -458,7 +459,8 @@ public void testAMRMClientOnAMRMTokenRollOverOnRMRestart() throws Exception { .getMasterKey().getKeyId() == newToken.decodeIdentifier().getKeyId()); // start 2nd RM - conf.set(YarnConfiguration.RM_SCHEDULER_ADDRESS, "0.0.0.0:9030"); + 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());