diff --git hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/test/java/org/apache/hadoop/yarn/client/api/impl/TestAMRMClient.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/test/java/org/apache/hadoop/yarn/client/api/impl/TestAMRMClient.java index 38178a4..76cb31a 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/test/java/org/apache/hadoop/yarn/client/api/impl/TestAMRMClient.java +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/test/java/org/apache/hadoop/yarn/client/api/impl/TestAMRMClient.java @@ -145,8 +145,21 @@ public static void setup() throws Exception { yarnClient.start(); // get node info - nodeReports = yarnClient.getNodeReports(NodeState.RUNNING); + for (int i = 0; i < DEFAULT_ITERATION; i++) { + nodeReports = yarnClient.getNodeReports(NodeState.RUNNING); + + if (!nodeReports.isEmpty()) { + break; + } + + sleep(50); + } + if (!nodeReports.isEmpty()) { + fail("No node managers were reported running within " + + DEFAULT_ITERATION + " iterations"); + } + priority = Priority.newInstance(1); priority2 = Priority.newInstance(2); capability = Resource.newInstance(1024, 1); @@ -1350,11 +1363,11 @@ public void testWaitFor() throws InterruptedException { } } - private void sleep(int sleepTime) { + private static void sleep(int sleepTime) { try { Thread.sleep(sleepTime); - } catch (InterruptedException e) { - e.printStackTrace(); + } catch (InterruptedException ex) { + Thread.currentThread().interrupt(); } }