Skip to content

Commit 2d6371c

Browse files
committed
Update Master.scala
1 parent 66362d5 commit 2d6371c

File tree

1 file changed

+6
-5
lines changed
  • core/src/main/scala/org/apache/spark/deploy/master

1 file changed

+6
-5
lines changed

core/src/main/scala/org/apache/spark/deploy/master/Master.scala

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -545,8 +545,8 @@ private[master] class Master(
545545
* worker by default, in which case only one executor may be launched on each worker.
546546
*/
547547

548-
private[master] def scheduleExecutorsOnWorkers(app: ApplicationInfo, usableWorkers: Array[WorkerInfo],
549-
spreadOutApps: Boolean): Array[Int] = {
548+
private[master] def scheduleExecutorsOnWorkers(app: ApplicationInfo,
549+
usableWorkers: Array[WorkerInfo], spreadOutApps: Boolean): Array[Int] = {
550550
val coresPerExecutor = app.desc.coresPerExecutor.getOrElse(1)
551551
val memoryPerExecutor = app.desc.memoryPerExecutorMB
552552
val numUsable = usableWorkers.length
@@ -580,9 +580,9 @@ private[master] class Master(
580580
}
581581
assignedCores
582582
}
583-
583+
584584
/**
585-
* Schedule and launch executors on workers
585+
* Schedule and launch executors on workers
586586
*/
587587
private def startExecutorsOnWorkers(): Unit = {
588588
// Right now this is a very simple FIFO scheduler. We keep trying to fit in the first app
@@ -598,7 +598,8 @@ private[master] class Master(
598598
// Now that we've decided how many cores to allocate on each worker, let's allocate them
599599
var pos = 0
600600
for (pos <- 0 until usableWorkers.length if assignedCores(pos) > 0) {
601-
allocateWorkerResourceToExecutors(app, assignedCores(pos), coresPerExecutor, usableWorkers(pos))
601+
allocateWorkerResourceToExecutors(app, assignedCores(pos), coresPerExecutor,
602+
usableWorkers(pos))
602603
}
603604
}
604605
}

0 commit comments

Comments
 (0)