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