src/slave/slave.cpp
// Called when an executor is exited.
// Transitions a live task to TASK_LOST/TASK_FAILED and sends status update.
Called when an executor is exited.
Transitions a live task to TASK_LOST/TASK_FAILED and sends status update.
Called when an executor is exited . Transitions a live task to TASK_LOST / TASK_FAILED and sends status update .
void Slave::transitionLiveTask(const TaskID& taskId,
                               const ExecutorID& executorId,
                               const FrameworkID& frameworkId,
                               bool isCommandExecutor,
                               int status)
{
  StatusUpdate update;
  if (isCommandExecutor) {
    update = createStatusUpdate(taskId,
                                executorId,
                                frameworkId,
                                TASK_FAILED,
                                "Executor running the task's command failed");
  } else {
    update = createStatusUpdate(taskId,
                                executorId,
                                frameworkId,
                                TASK_LOST,
                                "Executor exited");
  }
  statusUpdate(update);
}
void Slave :: transitionLiveTask ( const TaskID & taskId , const ExecutorID & executorId , const FrameworkID & frameworkId , bool isCommandExecutor , int status ) { StatusUpdate update ; if ( isCommandExecutor ) { update = createStatusUpdate ( taskId , executorId , frameworkId , TASK_FAILED , " " ) ; } else { update = createStatusUpdate ( taskId , executorId , frameworkId , TASK_LOST , " " ) ; } statusUpdate ( update ) ; }
Called when an executor is exited.
Called when an executor is exited .