org.apache.drill.yarn.appMaster

Class TaskState.EndingState

java.lang.Object

org.apache.drill.yarn.appMaster.TaskState

org.apache.drill.yarn.appMaster.TaskState.EndingState

Enclosing class:

TaskState

public static class TaskState.EndingState
extends TaskState

Task for which a termination request has been sent to the Drill-bit, but confirmation has not yet been received from the Node Manager. (Not yet supported in the Drill-bit.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.drill.yarn.appMaster.TaskState

TaskState.EndingState, TaskState.KillingState

Field Summary

Fields inherited from class org.apache.drill.yarn.appMaster.TaskState

cancellable, END, ENDING, hasContainer, KILLING, label, LAUNCHING, lifeCycleEvent, REQUESTING, RUNNING, START, WAIT_END_ACK, WAIT_START_ACK

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	EndingState()

Method Summary

Modifier and Type	Method and Description
void	cancel(EventContext context) Cluster manager wishes to cancel this task.
void	completionAck(EventContext context) The monitoring plugin has detected that the task has confirmed that it has started shutdown.
void	containerCompleted(EventContext context, org.apache.hadoop.yarn.api.records.ContainerStatus status) Normal ENDING --> WAIT_END_ACK | END transition.
void	tick(EventContext context, long curTime) If the graceful stop process exceeds the maximum timeout, go ahead and forcibly kill the process.

Methods inherited from class org.apache.drill.yarn.appMaster.TaskState

completed, containerAllocated, containerStarted, containerStopped, endOrAck, getLabel, hasContainer, isCancellable, launchFailed, requestContainer, startAck, stopTaskFailed, taskStartFailed, taskTerminated, toString, transition

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

EndingState

protected EndingState()

Method Detail

containerCompleted

public void containerCompleted(EventContext context,
                               org.apache.hadoop.yarn.api.records.ContainerStatus status)

Normal ENDING --> 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

tick

public void tick(EventContext context,
                 long curTime)

If the graceful stop process exceeds the maximum timeout, go ahead and forcibly kill the process.

Overrides:

tick 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