Skip to content

Commit cf7ac86

Browse files
committed
review feedback
1 parent 35314cb commit cf7ac86

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

core/src/main/scala/org/apache/spark/scheduler/cluster/CoarseGrainedSchedulerBackend.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -611,7 +611,7 @@ class CoarseGrainedSchedulerBackend(scheduler: TaskSchedulerImpl, val rpcEnv: Rp
611611
val executorsToKill = knownExecutors
612612
.filter { id => !executorsPendingToRemove.contains(id) }
613613
.filter { id => force || !scheduler.isExecutorBusy(id) }
614-
executorsToKill.foreach { id => executorsPendingToRemove(id) = !countFailures}
614+
executorsToKill.foreach { id => executorsPendingToRemove(id) = !countFailures }
615615

616616
logInfo(s"Actual list of executor(s) to be killed is ${executorsToKill.mkString(", ")}")
617617

0 commit comments

Comments
 (0)