|
@@ -219,6 +219,7 @@ public class TestAMRMClientOnRMRestart {
|
|
// request
|
|
// request
|
|
nm1.nodeHeartbeat(containerId.getApplicationAttemptId(),
|
|
nm1.nodeHeartbeat(containerId.getApplicationAttemptId(),
|
|
containerId.getContainerId(), ContainerState.RUNNING);
|
|
containerId.getContainerId(), ContainerState.RUNNING);
|
|
|
|
+ dispatcher.await();
|
|
amClient.requestContainerResourceChange(
|
|
amClient.requestContainerResourceChange(
|
|
container, Resource.newInstance(2048, 1));
|
|
container, Resource.newInstance(2048, 1));
|
|
it.remove();
|
|
it.remove();
|