Class TaskState.KillingState

java.lang.Object
org.apache.drill.yarn.appMaster.TaskState
org.apache.drill.yarn.appMaster.TaskState.KillingState
Enclosing class:
TaskState

public static class TaskState.KillingState extends TaskState
Task for which a forced termination request has been sent to the Node Manager, but a stop message has not yet been received.
  • Constructor Details

    • KillingState

      protected KillingState()
  • Method Details

    • containerCompleted

      public void containerCompleted(EventContext context, org.apache.hadoop.yarn.api.records.ContainerStatus status)
      Normal KILLING --> WAIT_END_ACK | END transition.
      Overrides:
      containerCompleted in class TaskState
      Parameters:
      status -
    • cancel

      public void cancel(EventContext context)
      Description copied from class: TaskState
      Cluster manager wishes to cancel this task.
      Overrides:
      cancel in class TaskState
    • startAck

      public void startAck(EventContext context)
      Description copied from class: TaskState
      The monitoring plugin has detected that the task has confirmed that it is fully started.
      Overrides:
      startAck in class TaskState
    • completionAck

      public void completionAck(EventContext context)
      Description copied from class: TaskState
      The monitoring plugin has detected that the task has confirmed that it has started shutdown.
      Overrides:
      completionAck in class TaskState
    • stopTaskFailed

      public void stopTaskFailed(EventContext context, Throwable t)
      Description copied from class: TaskState
      The node manager request to stop a task failed.
      Overrides:
      stopTaskFailed in class TaskState