Github user vanzin commented on a diff in the pull request: https://github.com/apache/spark/pull/19041#discussion_r155381466 --- Diff: core/src/main/scala/org/apache/spark/scheduler/cluster/CoarseGrainedSchedulerBackend.scala --- @@ -607,16 +614,17 @@ class CoarseGrainedSchedulerBackend(scheduler: TaskSchedulerImpl, val rpcEnv: Rp val response = synchronized { val (knownExecutors, unknownExecutors) = executorIds.partition(executorDataMap.contains) - unknownExecutors.foreach { id => - logWarning(s"Executor to kill $id does not exist!") - } + unknownExecutors.foreach(id => logWarning(s"Executor to kill $id does not exist!")) --- End diff -- nit: `.foreach { id =>`
--- --------------------------------------------------------------------- To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org