|
@@ -28,7 +28,6 @@ import java.util.List;
|
|
|
|
|
|
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;
|
|
@@ -88,6 +87,7 @@ public class TestAMRMClientOnRMRestart {
|
|
|
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");
|
|
|
}
|
|
|
|
|
|
// Test does major 6 steps verification.
|
|
@@ -489,8 +489,6 @@ public class TestAMRMClientOnRMRestart {
|
|
|
.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());
|