ExecutorBackend¶
ExecutorBackend
is an abstraction of executor backends (that TaskRunners use to report task status updates to a scheduler).
ExecutorBackend
acts as a bridge between executors and the driver.
Contract¶
Reporting Task Status¶
statusUpdate(
taskId: Long,
state: TaskState,
data: ByteBuffer): Unit
Reports task status of the given task to a scheduler
See:
Used when:
TaskRunner
is requested to run a task
Implementations¶
- CoarseGrainedExecutorBackend
- LocalSchedulerBackend
MesosExecutorBackend