YARN-8959. TestContainerResizing fails randomly (Ahmed Hussein via jeagles)
Signed-off-by: Jonathan Eagles <jeagles@gmail.com>
(cherry picked from commit 92e3ebb401
)
This commit is contained in:
parent
4e0d99c4d6
commit
7aade932c7
@ -224,7 +224,7 @@ protected Dispatcher createDispatcher() {
|
||||
verifyContainerDecreased(response, containerId1, 1 * GB);
|
||||
|
||||
// Wait for scheduler to finish processing kill events..
|
||||
dispatcher.waitForEventThreadToWait();
|
||||
dispatcher.await();
|
||||
|
||||
checkUsedResource(rm1, "default", 1 * GB, null);
|
||||
Assert.assertEquals(1 * GB,
|
||||
@ -657,7 +657,7 @@ protected Dispatcher createDispatcher() {
|
||||
// Trigger a node heartbeat..
|
||||
cs.handle(new NodeUpdateSchedulerEvent(rmNode1));
|
||||
|
||||
dispatcher.waitForEventThreadToWait();
|
||||
dispatcher.await();
|
||||
/* Check statuses after reservation satisfied */
|
||||
// Increase request should be unreserved
|
||||
Assert.assertTrue(app.getReservedContainers().isEmpty());
|
||||
@ -774,7 +774,7 @@ protected Dispatcher createDispatcher() {
|
||||
am1.allocate(null, null);
|
||||
|
||||
// Wait for scheduler to process all events.
|
||||
dispatcher.waitForEventThreadToWait();
|
||||
dispatcher.await();
|
||||
|
||||
/* Check statuses after reservation satisfied */
|
||||
// Increase request should be unreserved
|
||||
|
Loading…
Reference in New Issue
Block a user