|
@@ -94,7 +94,6 @@ public class TestApplicationMasterLauncher {
|
|
|
String nmHostAtContainerManager = null;
|
|
|
long submitTimeAtContainerManager;
|
|
|
int maxAppAttempts;
|
|
|
- private String queueName;
|
|
|
|
|
|
@Override
|
|
|
public StartContainersResponse
|
|
@@ -124,8 +123,6 @@ public class TestApplicationMasterLauncher {
|
|
|
Long.parseLong(env.get(ApplicationConstants.APP_SUBMIT_TIME_ENV));
|
|
|
maxAppAttempts =
|
|
|
Integer.parseInt(env.get(ApplicationConstants.MAX_APP_ATTEMPTS_ENV));
|
|
|
- queueName = env.get(ApplicationConstants.Environment
|
|
|
- .YARN_RESOURCEMANAGER_APPLICATION_QUEUE.key());
|
|
|
return StartContainersResponse.newInstance(
|
|
|
new HashMap<String, ByteBuffer>(), new ArrayList<ContainerId>(),
|
|
|
new HashMap<ContainerId, SerializedException>());
|
|
@@ -194,8 +191,6 @@ public class TestApplicationMasterLauncher {
|
|
|
containerManager.nmHostAtContainerManager);
|
|
|
Assert.assertEquals(YarnConfiguration.DEFAULT_RM_AM_MAX_ATTEMPTS,
|
|
|
containerManager.maxAppAttempts);
|
|
|
- Assert.assertEquals(YarnConfiguration.DEFAULT_QUEUE_NAME,
|
|
|
- containerManager.queueName);
|
|
|
|
|
|
MockAM am = new MockAM(rm.getRMContext(), rm
|
|
|
.getApplicationMasterService(), appAttemptId);
|