Skip to content
Snippets Groups Projects
Commit d9cf4d08 authored by Brenden Matthews's avatar Brenden Matthews Committed by Andrew Or
Browse files

[SPARK-3597][Mesos] Implement `killTask`.


The MesosSchedulerBackend did not previously implement `killTask`,
resulting in an exception.

Author: Brenden Matthews <brenden@diddyinc.com>

Closes #2453 from brndnmtthws/implement-killtask and squashes the following commits:

23ddcdc [Brenden Matthews] [SPARK-3597][Mesos] Implement `killTask`.

(cherry picked from commit 32fad423)
Signed-off-by: default avatarAndrew Or <andrewor14@gmail.com>
parent e4ddedee
No related branches found
No related tags found
No related merge requests found
......@@ -369,6 +369,13 @@ private[spark] class MesosSchedulerBackend(
recordSlaveLost(d, slaveId, ExecutorExited(status))
}
override def killTask(taskId: Long, executorId: String, interruptThread: Boolean): Unit = {
driver.killTask(
TaskID.newBuilder()
.setValue(taskId.toString).build()
)
}
// TODO: query Mesos for number of cores
override def defaultParallelism() = sc.conf.getInt("spark.default.parallelism", 8)
}
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment