Github user vanzin commented on a diff in the pull request: https://github.com/apache/spark/pull/19041#discussion_r143817365 --- Diff: core/src/main/scala/org/apache/spark/scheduler/cluster/CoarseGrainedSchedulerBackend.scala --- @@ -646,18 +648,14 @@ class CoarseGrainedSchedulerBackend(scheduler: TaskSchedulerImpl, val rpcEnv: Rp Future.successful(true) } - val killExecutors: Boolean => Future[Boolean] = - if (!executorsToKill.isEmpty) { - _ => doKillExecutors(executorsToKill) - } else { - _ => Future.successful(false) - } - - val killResponse = adjustTotalExecutors.flatMap(killExecutors)(ThreadUtils.sameThread) + val killResponse = if (executorsToKill.nonEmpty) { + adjustTotalExecutors.flatMap(_ => doKillExecutors(executorsToKill))(ThreadUtils.sameThread) --- End diff -- `.flatMap { _ => ... }`
--- --------------------------------------------------------------------- To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org