review commit

apache · Jun 10, 2014 · bc3aa66 · bc3aa66
1 parent 8800eba
commit bc3aa66
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/yarn/stable/src/main/scala/org/apache/spark/deploy/yarn/ExecutorLauncher.scala b/yarn/stable/src/main/scala/org/apache/spark/deploy/yarn/ExecutorLauncher.scala
@@ -201,9 +201,10 @@ class ExecutorLauncher(args: ApplicationMasterArguments, conf: Configuration, sp
     logInfo("Allocating " + args.numExecutors + " executors.")
     // Wait until all containers have finished
     yarnAllocator.addResourceRequests(args.numExecutors)
+    yarnAllocator.allocateResources()
     while ((yarnAllocator.getNumExecutorsRunning < args.numExecutors) && (!driverClosed)) {
-      yarnAllocator.allocateResources()
       allocateMissingExecutor()
+      yarnAllocator.allocateResources()
       Thread.sleep(100)
     }