Skip to content

Commit 66362d5

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

File tree

1 file changed

+2
-1
lines changed
  • core/src/main/scala/org/apache/spark/deploy/master

1 file changed

+2
-1
lines changed

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -569,7 +569,8 @@ private[master] class Master(
569569
// Pack executors into as few workers as possible (dense scheduling)
570570
while (toAssign > 0) {
571571
while (usableWorkers(pos).coresFree - assignedCores(pos) >= coresPerExecutor &&
572-
usableWorkers(pos).memoryFree - assignedMemory(pos) >= memoryPerExecutor) {
572+
usableWorkers(pos).memoryFree - assignedMemory(pos) >= memoryPerExecutor &&
573+
toAssign > 0) {
573574
toAssign -= coresPerExecutor
574575
assignedCores(pos) += coresPerExecutor
575576
assignedMemory(pos) += memoryPerExecutor

0 commit comments

Comments
 (0)