review commit

xiliu82 · Jun 9, 2014 · 32ac7af · 32ac7af
1 parent 056b8c7
commit 32ac7af
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/yarn/stable/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala b/yarn/stable/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala
@@ -253,11 +253,12 @@ class ApplicationMaster(args: ApplicationMasterArguments, conf: Configuration,
       logInfo("Allocating " + args.numExecutors + " executors.")
       // Wait until all containers have finished
       yarnAllocator.addResourceRequests(args.numExecutors)
+      yarnAllocator.allocateResources()
       // Exits the loop if the user thread exits.
       while (yarnAllocator.getNumExecutorsRunning < args.numExecutors && userThread.isAlive) {
-        yarnAllocator.allocateResources()
         checkNumExecutorsFailed()
         allocateMissingExecutor()
+        yarnAllocator.allocateResources()
         ApplicationMaster.incrementAllocatorLoop(1)
         Thread.sleep(100)
       }