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