holdenk commented on a change in pull request #31249:
URL: https://github.com/apache/spark/pull/31249#discussion_r562929926
##########
File path:
core/src/main/scala/org/apache/spark/scheduler/cluster/CoarseGrainedSchedulerBackend.scala
##########
@@ -850,6 +882,22 @@ class CoarseGrainedSchedulerBackend(scheduler:
TaskSchedulerImpl, val rpcEnv: Rp
protected def doKillExecutors(executorIds: Seq[String]): Future[Boolean] =
Future.successful(false)
+ /**
+ * Request that the cluster manager decommission all executors on a given
host.
+ * @return whether the decommission request is acknowledged.
+ */
+ final override def decommissionExecutorsOnHost(host: String): Boolean = {
+ logInfo(s"Requesting to kill any and all executors on host ${host}")
Review comment:
this matches the killExecsonHost code, so I'd either change both or not.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
