From 0f0707fb0db70e20705c9ba1be87735725f3ee6e Mon Sep 17 00:00:00 2001 From: Ahmed Hussein Date: Wed, 6 May 2020 12:48:12 -0500 Subject: [PATCH] YARN-8959. TestContainerResizing fails randomly (Ahmed Hussein via jeagles) Signed-off-by: Jonathan Eagles --- .../scheduler/capacity/TestContainerResizing.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/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 b/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 index 541539d892f..8161eb9b3ff 100644 --- a/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 +++ b/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 @@ -204,7 +204,7 @@ public class TestContainerResizing { 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, @@ -605,7 +605,7 @@ public class TestContainerResizing { // 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()); @@ -714,7 +714,7 @@ public class TestContainerResizing { 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