We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent bc91bb1 commit 2ca3091Copy full SHA for 2ca3091
core/src/main/scala/org/apache/spark/deploy/master/Master.scala
@@ -481,7 +481,8 @@ private[spark] class Master(
481
if (state != RecoveryState.ALIVE) { return }
482
483
// First schedule drivers, they take strict precedence over applications
484
- val shuffledAliveWorkers = Random.shuffle(workers.filter(_.state == WorkerState.ALIVE)) // Randomization helps balance drivers
+ // Randomization helps balance drivers
485
+ val shuffledAliveWorkers = Random.shuffle(workers.filter(_.state == WorkerState.ALIVE))
486
val aliveWorkerNum = shuffledAliveWorkers.size
487
var curPos = aliveWorkerNum - 1
488
for (driver <- List(waitingDrivers: _*)) {
0 commit comments