Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

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:
Ahmed Hussein 2020-05-06 12:27:17 -05:00 committed by Jonathan Eagles
parent dbb2809026
commit 4e29738f4c
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/TestContainerResizing.java
View File

@ -205,7 +205,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,
@ -606,7 +606,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());
@ -715,7 +715,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