diff --git hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/test/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/BaseContainerManagerTest.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/test/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/BaseContainerManagerTest.java index ad0a831..285b7e1 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/test/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/BaseContainerManagerTest.java +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/test/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/BaseContainerManagerTest.java @@ -314,13 +314,13 @@ public static void waitForContainerState( new HashSet<>(finalStates); int timeoutSecs = 0; do { - Thread.sleep(2000); containerStatus = containerManager.getContainerStatuses(request) .getContainerStatuses().get(0); LOG.info("Waiting for container to get into one of states " + fStates + ". Current state is " + containerStatus.getState()); timeoutSecs += 2; + Thread.sleep(10); } while (!fStates.contains(containerStatus.getState()) && timeoutSecs < timeOutMax); LOG.info("Container state is " + containerStatus.getState()); @@ -341,7 +341,7 @@ public static void waitForApplicationState( LOG.info("Waiting for app to reach " + finalState + ".. Current state is " + app.getApplicationState()); - Thread.sleep(1000); + Thread.sleep(10); } Assert.assertTrue("App is not in " + finalState + " yet!! Timedout!!", @@ -375,7 +375,6 @@ public static void waitForNMContainerState(ContainerManagerImpl .containermanager.container.ContainerState currentState = null; int timeoutSecs = 0; do { - Thread.sleep(2000); container = containerManager.getContext().getContainers().get(containerID); if (container != null) { @@ -386,8 +385,9 @@ public static void waitForNMContainerState(ContainerManagerImpl "states: " + finalStates + ". Current state is " + currentState); } timeoutSecs += 2; + Thread.sleep(10); } while (!finalStates.contains(currentState) - && timeoutSecs++ < timeOutMax); + && timeoutSecs < timeOutMax); LOG.info("Container state is " + currentState); Assert.assertTrue("ContainerState is not correct (timedout)", finalStates.contains(currentState));