public abstract class org.apache.drill.yarn.appMaster.TaskState extends java.lang.Object
{
private static final org.apache.commons.logging.Log LOG;
public static final org.apache.drill.yarn.appMaster.TaskState START;
public static final org.apache.drill.yarn.appMaster.TaskState REQUESTING;
public static final org.apache.drill.yarn.appMaster.TaskState LAUNCHING;
public static final org.apache.drill.yarn.appMaster.TaskState WAIT_START_ACK;
public static final org.apache.drill.yarn.appMaster.TaskState RUNNING;
public static final org.apache.drill.yarn.appMaster.TaskState ENDING;
public static final org.apache.drill.yarn.appMaster.TaskState KILLING;
public static final org.apache.drill.yarn.appMaster.TaskState WAIT_END_ACK;
public static final org.apache.drill.yarn.appMaster.TaskState END;
protected final boolean hasContainer;
protected final org.apache.drill.yarn.appMaster.TaskLifecycleListener$Event lifeCycleEvent;
protected final java.lang.String label;
protected final boolean cancellable;
static final boolean $assertionsDisabled;
public void <init>(boolean, org.apache.drill.yarn.appMaster.TaskLifecycleListener$Event, boolean)
{
org.apache.drill.yarn.appMaster.TaskState v;
org.apache.drill.yarn.appMaster.TaskLifecycleListener$Event v;
java.lang.String v, v, v, v;
boolean v, v;
v := @this: org.apache.drill.yarn.appMaster.TaskState;
v := @parameter: boolean;
v := @parameter: org.apache.drill.yarn.appMaster.TaskLifecycleListener$Event;
v := @parameter: boolean;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.drill.yarn.appMaster.TaskState: boolean hasContainer> = v;
v.<org.apache.drill.yarn.appMaster.TaskState: org.apache.drill.yarn.appMaster.TaskLifecycleListener$Event lifeCycleEvent> = v;
v.<org.apache.drill.yarn.appMaster.TaskState: boolean cancellable> = v;
v = virtualinvoke v.<org.apache.drill.yarn.appMaster.TaskState: java.lang.String toString()>();
v = virtualinvoke v.<java.lang.String: java.lang.String replace(java.lang.CharSequence,java.lang.CharSequence)>("State", "");
v = virtualinvoke v.<java.lang.String: java.lang.String replaceAll(java.lang.String,java.lang.String)>("([a-z]+)([A-Z])", "$1_$2");
v = virtualinvoke v.<java.lang.String: java.lang.String toUpperCase()>();
v.<org.apache.drill.yarn.appMaster.TaskState: java.lang.String label> = v;
return;
}
protected void endOrAck(org.apache.drill.yarn.appMaster.EventContext)
{
org.apache.drill.yarn.appMaster.Task v;
org.apache.drill.yarn.appMaster.EventContext v;
org.apache.drill.yarn.appMaster.Task$TrackingState v, v;
org.apache.drill.yarn.appMaster.TaskState v, v;
v := @this: org.apache.drill.yarn.appMaster.TaskState;
v := @parameter: org.apache.drill.yarn.appMaster.EventContext;
v = v.<org.apache.drill.yarn.appMaster.EventContext: org.apache.drill.yarn.appMaster.Task task>;
v = v.<org.apache.drill.yarn.appMaster.Task: org.apache.drill.yarn.appMaster.Task$TrackingState trackingState>;
v = <org.apache.drill.yarn.appMaster.Task$TrackingState: org.apache.drill.yarn.appMaster.Task$TrackingState START_ACK>;
if v != v goto label;
v = <org.apache.drill.yarn.appMaster.TaskState: org.apache.drill.yarn.appMaster.TaskState WAIT_END_ACK>;
virtualinvoke v.<org.apache.drill.yarn.appMaster.TaskState: void transition(org.apache.drill.yarn.appMaster.EventContext,org.apache.drill.yarn.appMaster.TaskState)>(v, v);
goto label;
label:
virtualinvoke v.<org.apache.drill.yarn.appMaster.TaskState: void taskTerminated(org.apache.drill.yarn.appMaster.EventContext)>(v);
label:
return;
}
public void requestContainer(org.apache.drill.yarn.appMaster.EventContext)
{
org.apache.drill.yarn.appMaster.EventContext v;
org.apache.drill.yarn.appMaster.TaskState v;
v := @this: org.apache.drill.yarn.appMaster.TaskState;
v := @parameter: org.apache.drill.yarn.appMaster.EventContext;
specialinvoke v.<org.apache.drill.yarn.appMaster.TaskState: void illegalState(org.apache.drill.yarn.appMaster.EventContext,java.lang.String)>(v, "requestContainer");
return;
}
public void containerAllocated(org.apache.drill.yarn.appMaster.EventContext, org.apache.hadoop.yarn.api.records.Container)
{
org.apache.drill.yarn.appMaster.EventContext v;
org.apache.drill.yarn.appMaster.TaskState v;
org.apache.hadoop.yarn.api.records.Container v;
v := @this: org.apache.drill.yarn.appMaster.TaskState;
v := @parameter: org.apache.drill.yarn.appMaster.EventContext;
v := @parameter: org.apache.hadoop.yarn.api.records.Container;
specialinvoke v.<org.apache.drill.yarn.appMaster.TaskState: void illegalState(org.apache.drill.yarn.appMaster.EventContext,java.lang.String)>(v, "containerAllocated");
return;
}
public void launchFailed(org.apache.drill.yarn.appMaster.EventContext, java.lang.Throwable)
{
java.lang.Throwable v;
org.apache.drill.yarn.appMaster.EventContext v;
org.apache.drill.yarn.appMaster.TaskState v;
v := @this: org.apache.drill.yarn.appMaster.TaskState;
v := @parameter: org.apache.drill.yarn.appMaster.EventContext;
v := @parameter: java.lang.Throwable;
specialinvoke v.<org.apache.drill.yarn.appMaster.TaskState: void illegalState(org.apache.drill.yarn.appMaster.EventContext,java.lang.String)>(v, "launchFailed");
return;
}
public void containerStarted(org.apache.drill.yarn.appMaster.EventContext)
{
org.apache.drill.yarn.appMaster.EventContext v;
org.apache.drill.yarn.appMaster.TaskState v;
v := @this: org.apache.drill.yarn.appMaster.TaskState;
v := @parameter: org.apache.drill.yarn.appMaster.EventContext;
specialinvoke v.<org.apache.drill.yarn.appMaster.TaskState: void illegalState(org.apache.drill.yarn.appMaster.EventContext,java.lang.String)>(v, "containerStarted");
return;
}
public void startAck(org.apache.drill.yarn.appMaster.EventContext)
{
org.apache.drill.yarn.appMaster.EventContext v;
org.apache.drill.yarn.appMaster.TaskState v;
v := @this: org.apache.drill.yarn.appMaster.TaskState;
v := @parameter: org.apache.drill.yarn.appMaster.EventContext;
specialinvoke v.<org.apache.drill.yarn.appMaster.TaskState: void illegalState(org.apache.drill.yarn.appMaster.EventContext,java.lang.String)>(v, "startAck");
return;
}
public void stopTaskFailed(org.apache.drill.yarn.appMaster.EventContext, java.lang.Throwable)
{
java.lang.Throwable v;
org.apache.drill.yarn.appMaster.EventContext v;
org.apache.drill.yarn.appMaster.TaskState v;
v := @this: org.apache.drill.yarn.appMaster.TaskState;
v := @parameter: org.apache.drill.yarn.appMaster.EventContext;
v := @parameter: java.lang.Throwable;
specialinvoke v.<org.apache.drill.yarn.appMaster.TaskState: void illegalState(org.apache.drill.yarn.appMaster.EventContext,java.lang.String)>(v, "stopTaskFailed");
return;
}
public void completionAck(org.apache.drill.yarn.appMaster.EventContext)
{
org.apache.drill.yarn.appMaster.EventContext v;
org.apache.drill.yarn.appMaster.TaskState v;
v := @this: org.apache.drill.yarn.appMaster.TaskState;
v := @parameter: org.apache.drill.yarn.appMaster.EventContext;
specialinvoke v.<org.apache.drill.yarn.appMaster.TaskState: void illegalState(org.apache.drill.yarn.appMaster.EventContext,java.lang.String)>(v, "completionAck");
return;
}
public void containerStopped(org.apache.drill.yarn.appMaster.EventContext)
{
org.apache.drill.yarn.appMaster.EventContext v;
org.apache.drill.yarn.appMaster.TaskState v;
v := @this: org.apache.drill.yarn.appMaster.TaskState;
v := @parameter: org.apache.drill.yarn.appMaster.EventContext;
specialinvoke v.<org.apache.drill.yarn.appMaster.TaskState: void illegalState(org.apache.drill.yarn.appMaster.EventContext,java.lang.String)>(v, "containerStopped");
return;
}
public void containerCompleted(org.apache.drill.yarn.appMaster.EventContext, org.apache.hadoop.yarn.api.records.ContainerStatus)
{
org.apache.hadoop.yarn.api.records.ContainerStatus v;
org.apache.drill.yarn.appMaster.EventContext v;
org.apache.drill.yarn.appMaster.TaskState v;
v := @this: org.apache.drill.yarn.appMaster.TaskState;
v := @parameter: org.apache.drill.yarn.appMaster.EventContext;
v := @parameter: org.apache.hadoop.yarn.api.records.ContainerStatus;
virtualinvoke v.<org.apache.drill.yarn.appMaster.TaskState: void completed(org.apache.drill.yarn.appMaster.EventContext,org.apache.hadoop.yarn.api.records.ContainerStatus)>(v, v);
specialinvoke v.<org.apache.drill.yarn.appMaster.TaskState: void illegalState(org.apache.drill.yarn.appMaster.EventContext,java.lang.String)>(v, "containerCompleted");
return;
}
public void cancel(org.apache.drill.yarn.appMaster.EventContext)
{
org.apache.drill.yarn.appMaster.EventContext v;
org.apache.drill.yarn.appMaster.TaskState v;
v := @this: org.apache.drill.yarn.appMaster.TaskState;
v := @parameter: org.apache.drill.yarn.appMaster.EventContext;
specialinvoke v.<org.apache.drill.yarn.appMaster.TaskState: void illegalState(org.apache.drill.yarn.appMaster.EventContext,java.lang.String)>(v, "cancel");
return;
}
public void tick(org.apache.drill.yarn.appMaster.EventContext, long)
{
long v;
org.apache.drill.yarn.appMaster.EventContext v;
org.apache.drill.yarn.appMaster.TaskState v;
v := @this: org.apache.drill.yarn.appMaster.TaskState;
v := @parameter: org.apache.drill.yarn.appMaster.EventContext;
v := @parameter: long;
return;
}
protected void transition(org.apache.drill.yarn.appMaster.EventContext, org.apache.drill.yarn.appMaster.TaskState)
{
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
long v;
org.apache.drill.yarn.appMaster.TaskState v, v, v;
java.lang.String v, v, v, v;
org.apache.drill.yarn.appMaster.TaskLifecycleListener$Event v, v, v;
org.apache.drill.yarn.appMaster.Task v, v, v, v;
org.apache.drill.yarn.appMaster.EventContext v;
org.apache.commons.logging.Log v;
v := @this: org.apache.drill.yarn.appMaster.TaskState;
v := @parameter: org.apache.drill.yarn.appMaster.EventContext;
v := @parameter: org.apache.drill.yarn.appMaster.TaskState;
v = v.<org.apache.drill.yarn.appMaster.EventContext: org.apache.drill.yarn.appMaster.Task task>;
v = v.<org.apache.drill.yarn.appMaster.Task: org.apache.drill.yarn.appMaster.TaskState state>;
v = <org.apache.drill.yarn.appMaster.TaskState: org.apache.commons.logging.Log LOG>;
v = v.<org.apache.drill.yarn.appMaster.EventContext: org.apache.drill.yarn.appMaster.Task task>;
v = virtualinvoke v.<org.apache.drill.yarn.appMaster.Task: java.lang.String getLabel()>();
v = virtualinvoke v.<org.apache.drill.yarn.appMaster.TaskState: java.lang.String toString()>();
v = virtualinvoke v.<org.apache.drill.yarn.appMaster.TaskState: java.lang.String toString()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,java.lang.String)>(v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u \u --> \u0001");
interfaceinvoke v.<org.apache.commons.logging.Log: void info(java.lang.Object)>(v);
v = v.<org.apache.drill.yarn.appMaster.EventContext: org.apache.drill.yarn.appMaster.Task task>;
v.<org.apache.drill.yarn.appMaster.Task: org.apache.drill.yarn.appMaster.TaskState state> = v;
v = v.<org.apache.drill.yarn.appMaster.TaskState: org.apache.drill.yarn.appMaster.TaskLifecycleListener$Event lifeCycleEvent>;
v = v.<org.apache.drill.yarn.appMaster.TaskState: org.apache.drill.yarn.appMaster.TaskLifecycleListener$Event lifeCycleEvent>;
if v == v goto label;
v = v.<org.apache.drill.yarn.appMaster.EventContext: org.apache.drill.yarn.appMaster.ClusterControllerImpl controller>;
v = v.<org.apache.drill.yarn.appMaster.TaskState: org.apache.drill.yarn.appMaster.TaskLifecycleListener$Event lifeCycleEvent>;
virtualinvoke v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: void fireLifecycleChange(org.apache.drill.yarn.appMaster.TaskLifecycleListener$Event,org.apache.drill.yarn.appMaster.EventContext)>(v, v);
label:
v = v.<org.apache.drill.yarn.appMaster.EventContext: org.apache.drill.yarn.appMaster.Task task>;
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v.<org.apache.drill.yarn.appMaster.Task: long stateStartTime> = v;
return;
}
protected void taskStartFailed(org.apache.drill.yarn.appMaster.EventContext, org.apache.drill.yarn.appMaster.Task$Disposition)
{
org.apache.drill.yarn.appMaster.Scheduler$TaskManager v;
java.lang.AssertionError v;
org.apache.drill.yarn.appMaster.TaskState v;
org.apache.hadoop.yarn.api.records.Container v;
org.apache.drill.yarn.appMaster.Task$Disposition v;
org.apache.drill.yarn.appMaster.Task v;
org.apache.drill.yarn.appMaster.EventContext v;
boolean v;
v := @this: org.apache.drill.yarn.appMaster.TaskState;
v := @parameter: org.apache.drill.yarn.appMaster.EventContext;
v := @parameter: org.apache.drill.yarn.appMaster.Task$Disposition;
v = <org.apache.drill.yarn.appMaster.TaskState: boolean $assertionsDisabled>;
if v != 0 goto label;
v = v.<org.apache.drill.yarn.appMaster.EventContext: org.apache.drill.yarn.appMaster.Task task>;
v = v.<org.apache.drill.yarn.appMaster.Task: org.apache.hadoop.yarn.api.records.Container container>;
if v == null goto label;
v = new java.lang.AssertionError;
specialinvoke v.<java.lang.AssertionError: void <init>()>();
throw v;
label:
v = virtualinvoke v.<org.apache.drill.yarn.appMaster.EventContext: org.apache.drill.yarn.appMaster.Scheduler$TaskManager getTaskManager()>();
interfaceinvoke v.<org.apache.drill.yarn.appMaster.Scheduler$TaskManager: void completed(org.apache.drill.yarn.appMaster.EventContext)>(v);
specialinvoke v.<org.apache.drill.yarn.appMaster.TaskState: void taskEnded(org.apache.drill.yarn.appMaster.EventContext,org.apache.drill.yarn.appMaster.Task$Disposition)>(v, v);
specialinvoke v.<org.apache.drill.yarn.appMaster.TaskState: void retryTask(org.apache.drill.yarn.appMaster.EventContext)>(v);
return;
}
protected void taskTerminated(org.apache.drill.yarn.appMaster.EventContext)
{
org.apache.drill.yarn.appMaster.Scheduler$TaskManager v;
java.lang.AssertionError v;
org.apache.drill.yarn.appMaster.TaskState v;
org.apache.drill.yarn.appMaster.Task$Disposition v, v;
org.apache.hadoop.yarn.api.records.ContainerStatus v, v;
org.apache.drill.yarn.appMaster.Task v, v;
org.apache.drill.yarn.appMaster.EventContext v;
int v;
org.apache.drill.yarn.appMaster.SchedulerStateImpl v, v;
boolean v;
v := @this: org.apache.drill.yarn.appMaster.TaskState;
v := @parameter: org.apache.drill.yarn.appMaster.EventContext;
v = v.<org.apache.drill.yarn.appMaster.EventContext: org.apache.drill.yarn.appMaster.Task task>;
v = virtualinvoke v.<org.apache.drill.yarn.appMaster.EventContext: org.apache.drill.yarn.appMaster.Scheduler$TaskManager getTaskManager()>();
interfaceinvoke v.<org.apache.drill.yarn.appMaster.Scheduler$TaskManager: void completed(org.apache.drill.yarn.appMaster.EventContext)>(v);
v = v.<org.apache.drill.yarn.appMaster.EventContext: org.apache.drill.yarn.appMaster.SchedulerStateImpl group>;
virtualinvoke v.<org.apache.drill.yarn.appMaster.SchedulerStateImpl: void containerReleased(org.apache.drill.yarn.appMaster.Task)>(v);
v = <org.apache.drill.yarn.appMaster.TaskState: boolean $assertionsDisabled>;
if v != 0 goto label;
v = v.<org.apache.drill.yarn.appMaster.Task: org.apache.hadoop.yarn.api.records.ContainerStatus completionStatus>;
if v != null goto label;
v = new java.lang.AssertionError;
specialinvoke v.<java.lang.AssertionError: void <init>()>();
throw v;
label:
v = v.<org.apache.drill.yarn.appMaster.Task: org.apache.hadoop.yarn.api.records.ContainerStatus completionStatus>;
v = virtualinvoke v.<org.apache.hadoop.yarn.api.records.ContainerStatus: int getExitStatus()>();
if v != 0 goto label;
v = <org.apache.drill.yarn.appMaster.Task$Disposition: org.apache.drill.yarn.appMaster.Task$Disposition COMPLETED>;
specialinvoke v.<org.apache.drill.yarn.appMaster.TaskState: void taskEnded(org.apache.drill.yarn.appMaster.EventContext,org.apache.drill.yarn.appMaster.Task$Disposition)>(v, v);
v = v.<org.apache.drill.yarn.appMaster.EventContext: org.apache.drill.yarn.appMaster.SchedulerStateImpl group>;
v = v.<org.apache.drill.yarn.appMaster.EventContext: org.apache.drill.yarn.appMaster.Task task>;
virtualinvoke v.<org.apache.drill.yarn.appMaster.SchedulerStateImpl: void taskEnded(org.apache.drill.yarn.appMaster.Task)>(v);
goto label;
label:
v = <org.apache.drill.yarn.appMaster.Task$Disposition: org.apache.drill.yarn.appMaster.Task$Disposition RUN_FAILED>;
specialinvoke v.<org.apache.drill.yarn.appMaster.TaskState: void taskEnded(org.apache.drill.yarn.appMaster.EventContext,org.apache.drill.yarn.appMaster.Task$Disposition)>(v, v);
specialinvoke v.<org.apache.drill.yarn.appMaster.TaskState: void retryTask(org.apache.drill.yarn.appMaster.EventContext)>(v);
label:
return;
}
private void taskEnded(org.apache.drill.yarn.appMaster.EventContext, org.apache.drill.yarn.appMaster.Task$Disposition)
{
long v;
java.lang.AssertionError v;
org.apache.drill.yarn.appMaster.TaskState v, v;
org.apache.drill.yarn.appMaster.Task$Disposition v, v;
org.apache.drill.yarn.appMaster.Task v;
org.apache.drill.yarn.appMaster.EventContext v;
boolean v;
v := @this: org.apache.drill.yarn.appMaster.TaskState;
v := @parameter: org.apache.drill.yarn.appMaster.EventContext;
v := @parameter: org.apache.drill.yarn.appMaster.Task$Disposition;
v = v.<org.apache.drill.yarn.appMaster.EventContext: org.apache.drill.yarn.appMaster.Task task>;
if v != null goto label;
v = <org.apache.drill.yarn.appMaster.TaskState: boolean $assertionsDisabled>;
if v != 0 goto label;
v = v.<org.apache.drill.yarn.appMaster.Task: org.apache.drill.yarn.appMaster.Task$Disposition disposition>;
if v != null goto label;
v = new java.lang.AssertionError;
specialinvoke v.<java.lang.AssertionError: void <init>()>();
throw v;
label:
v.<org.apache.drill.yarn.appMaster.Task: org.apache.drill.yarn.appMaster.Task$Disposition disposition> = v;
label:
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v.<org.apache.drill.yarn.appMaster.Task: long completionTime> = v;
v = <org.apache.drill.yarn.appMaster.TaskState: org.apache.drill.yarn.appMaster.TaskState END>;
virtualinvoke v.<org.apache.drill.yarn.appMaster.TaskState: void transition(org.apache.drill.yarn.appMaster.EventContext,org.apache.drill.yarn.appMaster.TaskState)>(v, v);
return;
}
private void retryTask(org.apache.drill.yarn.appMaster.EventContext)
{
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
java.lang.AssertionError v;
org.apache.drill.yarn.appMaster.TaskState v, v, v, v;
org.apache.drill.yarn.appMaster.Task$Disposition v;
int v, v, v, v;
java.lang.String v, v, v, v;
boolean v, v, v;
org.apache.drill.yarn.appMaster.Task v;
org.apache.drill.yarn.appMaster.EventContext v;
org.apache.commons.logging.Log v, v;
org.apache.drill.yarn.appMaster.SchedulerStateImpl v, v, v, v, v;
v := @this: org.apache.drill.yarn.appMaster.TaskState;
v := @parameter: org.apache.drill.yarn.appMaster.EventContext;
v = v.<org.apache.drill.yarn.appMaster.EventContext: org.apache.drill.yarn.appMaster.Task task>;
v = <org.apache.drill.yarn.appMaster.TaskState: boolean $assertionsDisabled>;
if v != 0 goto label;
v = v.<org.apache.drill.yarn.appMaster.Task: org.apache.drill.yarn.appMaster.TaskState state>;
v = <org.apache.drill.yarn.appMaster.TaskState: org.apache.drill.yarn.appMaster.TaskState END>;
if v == v goto label;
v = new java.lang.AssertionError;
specialinvoke v.<java.lang.AssertionError: void <init>()>();
throw v;
label:
v = v.<org.apache.drill.yarn.appMaster.EventContext: org.apache.drill.yarn.appMaster.ClusterControllerImpl controller>;
v = virtualinvoke v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: boolean isLive()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.drill.yarn.appMaster.Task: boolean retryable()>();
if v != 0 goto label;
label:
v = v.<org.apache.drill.yarn.appMaster.EventContext: org.apache.drill.yarn.appMaster.SchedulerStateImpl group>;
virtualinvoke v.<org.apache.drill.yarn.appMaster.SchedulerStateImpl: void taskEnded(org.apache.drill.yarn.appMaster.Task)>(v);
return;
label:
v = v.<org.apache.drill.yarn.appMaster.Task: int tryCount>;
v = v.<org.apache.drill.yarn.appMaster.Task: org.apache.drill.yarn.appMaster.SchedulerStateImpl taskGroup>;
v = virtualinvoke v.<org.apache.drill.yarn.appMaster.SchedulerStateImpl: int getMaxRetries()>();
if v <= v goto label;
v = <org.apache.drill.yarn.appMaster.TaskState: org.apache.commons.logging.Log LOG>;
v = virtualinvoke v.<org.apache.drill.yarn.appMaster.Task: java.lang.String getLabel()>();
v = v.<org.apache.drill.yarn.appMaster.Task: int tryCount>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,int)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u - Too many retries: \u0001");
interfaceinvoke v.<org.apache.commons.logging.Log: void error(java.lang.Object)>(v);
v = <org.apache.drill.yarn.appMaster.Task$Disposition: org.apache.drill.yarn.appMaster.Task$Disposition TOO_MANY_RETRIES>;
v.<org.apache.drill.yarn.appMaster.Task: org.apache.drill.yarn.appMaster.Task$Disposition disposition> = v;
v = v.<org.apache.drill.yarn.appMaster.EventContext: org.apache.drill.yarn.appMaster.SchedulerStateImpl group>;
virtualinvoke v.<org.apache.drill.yarn.appMaster.SchedulerStateImpl: void taskEnded(org.apache.drill.yarn.appMaster.Task)>(v);
return;
label:
v = <org.apache.drill.yarn.appMaster.TaskState: org.apache.commons.logging.Log LOG>;
v = virtualinvoke v.<org.apache.drill.yarn.appMaster.Task: java.lang.String getLabel()>();
v = v.<org.apache.drill.yarn.appMaster.Task: int tryCount>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,int)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u - Retrying task, try \u0001");
interfaceinvoke v.<org.apache.commons.logging.Log: void info(java.lang.Object)>(v);
v = v.<org.apache.drill.yarn.appMaster.EventContext: org.apache.drill.yarn.appMaster.SchedulerStateImpl group>;
virtualinvoke v.<org.apache.drill.yarn.appMaster.SchedulerStateImpl: void taskRetried(org.apache.drill.yarn.appMaster.Task)>(v);
virtualinvoke v.<org.apache.drill.yarn.appMaster.Task: void reset()>();
v = <org.apache.drill.yarn.appMaster.TaskState: org.apache.drill.yarn.appMaster.TaskState START>;
virtualinvoke v.<org.apache.drill.yarn.appMaster.TaskState: void transition(org.apache.drill.yarn.appMaster.EventContext,org.apache.drill.yarn.appMaster.TaskState)>(v, v);
v = v.<org.apache.drill.yarn.appMaster.EventContext: org.apache.drill.yarn.appMaster.SchedulerStateImpl group>;
virtualinvoke v.<org.apache.drill.yarn.appMaster.SchedulerStateImpl: void enqueuePendingRequest(org.apache.drill.yarn.appMaster.Task)>(v);
return;
}
private void illegalState(org.apache.drill.yarn.appMaster.EventContext, java.lang.String)
{
java.lang.IllegalStateException v;
java.lang.AssertionError v;
org.apache.drill.yarn.appMaster.TaskState v;
org.apache.drill.yarn.appMaster.Task v;
org.apache.drill.yarn.appMaster.EventContext v;
org.apache.commons.logging.Log v;
java.lang.String v, v, v, v;
boolean v;
v := @this: org.apache.drill.yarn.appMaster.TaskState;
v := @parameter: org.apache.drill.yarn.appMaster.EventContext;
v := @parameter: java.lang.String;
v = <org.apache.drill.yarn.appMaster.TaskState: boolean $assertionsDisabled>;
if v != 0 goto label;
v = new java.lang.AssertionError;
specialinvoke v.<java.lang.AssertionError: void <init>()>();
throw v;
label:
v = <org.apache.drill.yarn.appMaster.TaskState: org.apache.commons.logging.Log LOG>;
v = v.<org.apache.drill.yarn.appMaster.EventContext: org.apache.drill.yarn.appMaster.Task task>;
v = virtualinvoke v.<org.apache.drill.yarn.appMaster.Task: java.lang.String getLabel()>();
v = virtualinvoke v.<org.apache.drill.yarn.appMaster.TaskState: java.lang.String toString()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,java.lang.String)>(v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u - Action \u in wrong state: \u0001");
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("Action in wrong state");
interfaceinvoke v.<org.apache.commons.logging.Log: void error(java.lang.Object,java.lang.Throwable)>(v, v);
return;
}
protected void completed(org.apache.drill.yarn.appMaster.EventContext, org.apache.hadoop.yarn.api.records.ContainerStatus)
{
org.apache.drill.yarn.appMaster.TaskState v;
org.apache.hadoop.yarn.api.records.ContainerStatus v;
org.apache.drill.yarn.appMaster.Task v;
org.apache.drill.yarn.appMaster.EventContext v;
int v;
org.apache.commons.logging.Log v;
java.lang.String v, v, v, v, v;
boolean v;
v := @this: org.apache.drill.yarn.appMaster.TaskState;
v := @parameter: org.apache.drill.yarn.appMaster.EventContext;
v := @parameter: org.apache.hadoop.yarn.api.records.ContainerStatus;
v = v.<org.apache.drill.yarn.appMaster.EventContext: org.apache.drill.yarn.appMaster.Task task>;
v = virtualinvoke v.<org.apache.hadoop.yarn.api.records.ContainerStatus: java.lang.String getDiagnostics()>();
v = <org.apache.drill.yarn.appMaster.TaskState: org.apache.commons.logging.Log LOG>;
v = virtualinvoke v.<org.apache.drill.yarn.appMaster.Task: java.lang.String getLabel()>();
v = virtualinvoke v.<org.apache.hadoop.yarn.api.records.ContainerStatus: int getExitStatus()>();
v = staticinvoke <org.apache.drill.yarn.core.DoYUtil: boolean isBlank(java.lang.String)>(v);
if v == 0 goto label;
v = "";
goto label;
label:
v = virtualinvoke v.<org.apache.hadoop.yarn.api.records.ContainerStatus: java.lang.String getDiagnostics()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>(": \u0001");
label:
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,int,java.lang.String)>(v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u Completed, exit status: \u0001\u0001");
interfaceinvoke v.<org.apache.commons.logging.Log: void trace(java.lang.Object)>(v);
v.<org.apache.drill.yarn.appMaster.Task: org.apache.hadoop.yarn.api.records.ContainerStatus completionStatus> = v;
return;
}
public java.lang.String toString()
{
java.lang.Class v;
java.lang.String v;
org.apache.drill.yarn.appMaster.TaskState v;
v := @this: org.apache.drill.yarn.appMaster.TaskState;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
return v;
}
public boolean hasContainer()
{
org.apache.drill.yarn.appMaster.TaskState v;
boolean v;
v := @this: org.apache.drill.yarn.appMaster.TaskState;
v = v.<org.apache.drill.yarn.appMaster.TaskState: boolean hasContainer>;
return v;
}
public java.lang.String getLabel()
{
java.lang.String v;
org.apache.drill.yarn.appMaster.TaskState v;
v := @this: org.apache.drill.yarn.appMaster.TaskState;
v = v.<org.apache.drill.yarn.appMaster.TaskState: java.lang.String label>;
return v;
}
public boolean isCancellable()
{
org.apache.drill.yarn.appMaster.TaskState v;
boolean v;
v := @this: org.apache.drill.yarn.appMaster.TaskState;
v = v.<org.apache.drill.yarn.appMaster.TaskState: boolean cancellable>;
return v;
}
static void <clinit>()
{
org.apache.drill.yarn.appMaster.TaskState$EndingState v;
org.apache.drill.yarn.appMaster.TaskState$KillingState v;
org.apache.drill.yarn.appMaster.TaskState$LaunchingState v;
org.apache.drill.yarn.appMaster.TaskState$WaitStartAckState v;
org.apache.drill.yarn.appMaster.TaskState$RequestingState v;
org.apache.drill.yarn.appMaster.TaskState$RunningState v;
org.apache.drill.yarn.appMaster.TaskState$StartState v;
java.lang.Class v;
org.apache.commons.logging.Log v;
org.apache.drill.yarn.appMaster.TaskState$WaitEndAckState v;
org.apache.drill.yarn.appMaster.TaskState$EndState v;
boolean v, v;
v = class "Lorg/apache/drill/yarn/appMaster/TaskState;";
v = virtualinvoke v.<java.lang.Class: boolean desiredAssertionStatus()>();
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
<org.apache.drill.yarn.appMaster.TaskState: boolean $assertionsDisabled> = v;
v = staticinvoke <org.apache.commons.logging.LogFactory: org.apache.commons.logging.Log getLog(java.lang.Class)>(class "Lorg/apache/drill/yarn/appMaster/TaskState;");
<org.apache.drill.yarn.appMaster.TaskState: org.apache.commons.logging.Log LOG> = v;
v = new org.apache.drill.yarn.appMaster.TaskState$StartState;
specialinvoke v.<org.apache.drill.yarn.appMaster.TaskState$StartState: void <init>()>();
<org.apache.drill.yarn.appMaster.TaskState: org.apache.drill.yarn.appMaster.TaskState START> = v;
v = new org.apache.drill.yarn.appMaster.TaskState$RequestingState;
specialinvoke v.<org.apache.drill.yarn.appMaster.TaskState$RequestingState: void <init>()>();
<org.apache.drill.yarn.appMaster.TaskState: org.apache.drill.yarn.appMaster.TaskState REQUESTING> = v;
v = new org.apache.drill.yarn.appMaster.TaskState$LaunchingState;
specialinvoke v.<org.apache.drill.yarn.appMaster.TaskState$LaunchingState: void <init>()>();
<org.apache.drill.yarn.appMaster.TaskState: org.apache.drill.yarn.appMaster.TaskState LAUNCHING> = v;
v = new org.apache.drill.yarn.appMaster.TaskState$WaitStartAckState;
specialinvoke v.<org.apache.drill.yarn.appMaster.TaskState$WaitStartAckState: void <init>()>();
<org.apache.drill.yarn.appMaster.TaskState: org.apache.drill.yarn.appMaster.TaskState WAIT_START_ACK> = v;
v = new org.apache.drill.yarn.appMaster.TaskState$RunningState;
specialinvoke v.<org.apache.drill.yarn.appMaster.TaskState$RunningState: void <init>()>();
<org.apache.drill.yarn.appMaster.TaskState: org.apache.drill.yarn.appMaster.TaskState RUNNING> = v;
v = new org.apache.drill.yarn.appMaster.TaskState$EndingState;
specialinvoke v.<org.apache.drill.yarn.appMaster.TaskState$EndingState: void <init>()>();
<org.apache.drill.yarn.appMaster.TaskState: org.apache.drill.yarn.appMaster.TaskState ENDING> = v;
v = new org.apache.drill.yarn.appMaster.TaskState$KillingState;
specialinvoke v.<org.apache.drill.yarn.appMaster.TaskState$KillingState: void <init>()>();
<org.apache.drill.yarn.appMaster.TaskState: org.apache.drill.yarn.appMaster.TaskState KILLING> = v;
v = new org.apache.drill.yarn.appMaster.TaskState$WaitEndAckState;
specialinvoke v.<org.apache.drill.yarn.appMaster.TaskState$WaitEndAckState: void <init>()>();
<org.apache.drill.yarn.appMaster.TaskState: org.apache.drill.yarn.appMaster.TaskState WAIT_END_ACK> = v;
v = new org.apache.drill.yarn.appMaster.TaskState$EndState;
specialinvoke v.<org.apache.drill.yarn.appMaster.TaskState$EndState: void <init>()>();
<org.apache.drill.yarn.appMaster.TaskState: org.apache.drill.yarn.appMaster.TaskState END> = v;
return;
}
}