|
@@ -204,7 +204,7 @@ public class TestContainerResizing {
|
|
verifyContainerDecreased(response, containerId1, 1 * GB);
|
|
verifyContainerDecreased(response, containerId1, 1 * GB);
|
|
|
|
|
|
// Wait for scheduler to finish processing kill events..
|
|
// Wait for scheduler to finish processing kill events..
|
|
- dispatcher.waitForEventThreadToWait();
|
|
|
|
|
|
+ dispatcher.await();
|
|
|
|
|
|
checkUsedResource(rm1, "default", 1 * GB, null);
|
|
checkUsedResource(rm1, "default", 1 * GB, null);
|
|
Assert.assertEquals(1 * GB,
|
|
Assert.assertEquals(1 * GB,
|
|
@@ -605,7 +605,7 @@ public class TestContainerResizing {
|
|
// Trigger a node heartbeat..
|
|
// Trigger a node heartbeat..
|
|
cs.handle(new NodeUpdateSchedulerEvent(rmNode1));
|
|
cs.handle(new NodeUpdateSchedulerEvent(rmNode1));
|
|
|
|
|
|
- dispatcher.waitForEventThreadToWait();
|
|
|
|
|
|
+ dispatcher.await();
|
|
/* Check statuses after reservation satisfied */
|
|
/* Check statuses after reservation satisfied */
|
|
// Increase request should be unreserved
|
|
// Increase request should be unreserved
|
|
Assert.assertTrue(app.getReservedContainers().isEmpty());
|
|
Assert.assertTrue(app.getReservedContainers().isEmpty());
|
|
@@ -714,7 +714,7 @@ public class TestContainerResizing {
|
|
am1.allocate(null, null);
|
|
am1.allocate(null, null);
|
|
|
|
|
|
// Wait for scheduler to process all events.
|
|
// Wait for scheduler to process all events.
|
|
- dispatcher.waitForEventThreadToWait();
|
|
|
|
|
|
+ dispatcher.await();
|
|
|
|
|
|
/* Check statuses after reservation satisfied */
|
|
/* Check statuses after reservation satisfied */
|
|
// Increase request should be unreserved
|
|
// Increase request should be unreserved
|