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..216bc94 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,25 @@ 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; + } + + try { + Thread.sleep(50L); + } catch (InterruptedException ex) { + Thread.currentThread().interrupt(); + } + } + 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);