Skip to content

Commit bc3aa66

Browse files
committed
review commit
1 parent 8800eba commit bc3aa66

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

yarn/stable/src/main/scala/org/apache/spark/deploy/yarn/ExecutorLauncher.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -201,9 +201,10 @@ class ExecutorLauncher(args: ApplicationMasterArguments, conf: Configuration, sp
201201
logInfo("Allocating " + args.numExecutors + " executors.")
202202
// Wait until all containers have finished
203203
yarnAllocator.addResourceRequests(args.numExecutors)
204+
yarnAllocator.allocateResources()
204205
while ((yarnAllocator.getNumExecutorsRunning < args.numExecutors) && (!driverClosed)) {
205-
yarnAllocator.allocateResources()
206206
allocateMissingExecutor()
207+
yarnAllocator.allocateResources()
207208
Thread.sleep(100)
208209
}
209210

0 commit comments

Comments
 (0)