public class org.apache.drill.yarn.appMaster.ClusterControllerImpl extends java.lang.Object implements org.apache.drill.yarn.appMaster.ClusterController
{
private static final int PRIORITY_OFFSET;
private static final org.apache.commons.logging.Log LOG;
private java.lang.Object completionMutex;
protected int maxRetries;
org.apache.drill.yarn.appMaster.ClusterControllerImpl$State state;
private java.util.Map taskPools;
private java.util.List prioritizedGroups;
private java.util.Set allocatedContainers;
private java.util.Map activeContainers;
private java.util.List completedTasks;
private final org.apache.drill.yarn.appMaster.AMYarnFacade yarn;
private int maxRequestsPerTick;
private int stopTimoutMs;
private int configPollPeriod;
private long nextResourcePollTime;
private org.apache.drill.yarn.appMaster.NodeInventory nodeInventory;
private long lastFailureCheckTime;
private int failureCheckPeriodMs;
private int taskCheckPeriodMs;
private long lastTaskCheckTime;
private java.util.List lifecycleListeners;
private java.util.Map properties;
private boolean enableFailureCheck;
static final boolean $assertionsDisabled;
public void <init>(org.apache.drill.yarn.appMaster.AMYarnFacade)
{
org.apache.drill.yarn.appMaster.AMYarnFacade v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
java.util.HashMap v, v, v;
java.util.ArrayList v, v;
java.util.HashSet v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl$State v;
int v, v;
java.lang.Object v;
java.util.LinkedList v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v := @parameter: org.apache.drill.yarn.appMaster.AMYarnFacade;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new java.lang.Object;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.lang.Object completionMutex> = v;
v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: int maxRetries> = 3;
v = <org.apache.drill.yarn.appMaster.ClusterControllerImpl$State: org.apache.drill.yarn.appMaster.ClusterControllerImpl$State START>;
v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: org.apache.drill.yarn.appMaster.ClusterControllerImpl$State state> = v;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.util.Map taskPools> = v;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.util.List prioritizedGroups> = v;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.util.Set allocatedContainers> = v;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.util.Map activeContainers> = v;
v = new java.util.LinkedList;
specialinvoke v.<java.util.LinkedList: void <init>()>();
v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.util.List completedTasks> = v;
v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: int maxRequestsPerTick> = 2;
v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: int stopTimoutMs> = 10000;
v = (int) 60000;
v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: int configPollPeriod> = v;
v = (int) 60000;
v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: int failureCheckPeriodMs> = v;
v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: int taskCheckPeriodMs> = 10000;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.util.List lifecycleListeners> = v;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.util.Map properties> = v;
v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: boolean enableFailureCheck> = 1;
v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: org.apache.drill.yarn.appMaster.AMYarnFacade yarn> = v;
return;
}
public void enableFailureCheck(boolean)
{
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
boolean v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v := @parameter: boolean;
v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: boolean enableFailureCheck> = v;
return;
}
public void registerScheduler(org.apache.drill.yarn.appMaster.Scheduler)
{
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
java.lang.AssertionError v;
java.util.List v;
java.util.Map v, v, v;
org.apache.drill.yarn.appMaster.Scheduler v;
int v, v;
java.lang.String v, v;
org.apache.drill.yarn.appMaster.SchedulerStateImpl v;
boolean v, v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v := @parameter: org.apache.drill.yarn.appMaster.Scheduler;
v = <org.apache.drill.yarn.appMaster.ClusterControllerImpl: boolean $assertionsDisabled>;
if v != 0 goto label;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.util.Map taskPools>;
v = interfaceinvoke v.<org.apache.drill.yarn.appMaster.Scheduler: java.lang.String getName()>();
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>(v);
if v == 0 goto label;
v = new java.lang.AssertionError;
specialinvoke v.<java.lang.AssertionError: void <init>()>();
throw v;
label:
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.util.Map taskPools>;
v = interfaceinvoke v.<java.util.Map: int size()>();
v = v + 1;
interfaceinvoke v.<org.apache.drill.yarn.appMaster.Scheduler: void setPriority(int)>(v);
v = new org.apache.drill.yarn.appMaster.SchedulerStateImpl;
specialinvoke v.<org.apache.drill.yarn.appMaster.SchedulerStateImpl: void <init>(org.apache.drill.yarn.appMaster.ClusterControllerImpl,org.apache.drill.yarn.appMaster.Scheduler)>(v, v);
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.util.Map taskPools>;
v = interfaceinvoke v.<org.apache.drill.yarn.appMaster.SchedulerStateActions: java.lang.String getName()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.util.List prioritizedGroups>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
return;
}
public synchronized void started() throws org.apache.drill.yarn.appMaster.YarnFacadeException, org.apache.drill.yarn.appMaster.AMException
{
org.apache.drill.yarn.appMaster.AMYarnFacade v, v;
java.util.Iterator v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
org.apache.drill.yarn.appMaster.NodeInventory v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl$State v;
java.util.List v;
org.apache.hadoop.yarn.api.protocolrecords.RegisterApplicationMasterResponse v;
org.apache.drill.yarn.appMaster.Scheduler v;
org.apache.hadoop.yarn.api.records.Resource v;
java.lang.Object v;
boolean v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v = new org.apache.drill.yarn.appMaster.NodeInventory;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: org.apache.drill.yarn.appMaster.AMYarnFacade yarn>;
specialinvoke v.<org.apache.drill.yarn.appMaster.NodeInventory: void <init>(org.apache.drill.yarn.appMaster.AMYarnFacade)>(v);
v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: org.apache.drill.yarn.appMaster.NodeInventory nodeInventory> = v;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: org.apache.drill.yarn.appMaster.AMYarnFacade yarn>;
v = interfaceinvoke v.<org.apache.drill.yarn.appMaster.AMYarnFacade: org.apache.hadoop.yarn.api.protocolrecords.RegisterApplicationMasterResponse getRegistrationResponse()>();
v = virtualinvoke v.<org.apache.hadoop.yarn.api.protocolrecords.RegisterApplicationMasterResponse: org.apache.hadoop.yarn.api.records.Resource getMaximumResourceCapability()>();
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.util.List prioritizedGroups>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<org.apache.drill.yarn.appMaster.SchedulerStateActions: org.apache.drill.yarn.appMaster.Scheduler getScheduler()>();
interfaceinvoke v.<org.apache.drill.yarn.appMaster.Scheduler: void limitContainerSize(org.apache.hadoop.yarn.api.records.Resource)>(v);
goto label;
label:
v = <org.apache.drill.yarn.appMaster.ClusterControllerImpl$State: org.apache.drill.yarn.appMaster.ClusterControllerImpl$State LIVE>;
v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: org.apache.drill.yarn.appMaster.ClusterControllerImpl$State state> = v;
return;
}
public synchronized void tick(long)
{
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
long v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl$State v, v, v, v, v, v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v := @parameter: long;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: org.apache.drill.yarn.appMaster.ClusterControllerImpl$State state>;
v = <org.apache.drill.yarn.appMaster.ClusterControllerImpl$State: org.apache.drill.yarn.appMaster.ClusterControllerImpl$State LIVE>;
if v != v goto label;
specialinvoke v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: void adjustTasks(long)>(v);
specialinvoke v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: void requestContainers()>();
label:
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: org.apache.drill.yarn.appMaster.ClusterControllerImpl$State state>;
v = <org.apache.drill.yarn.appMaster.ClusterControllerImpl$State: org.apache.drill.yarn.appMaster.ClusterControllerImpl$State LIVE>;
if v == v goto label;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: org.apache.drill.yarn.appMaster.ClusterControllerImpl$State state>;
v = <org.apache.drill.yarn.appMaster.ClusterControllerImpl$State: org.apache.drill.yarn.appMaster.ClusterControllerImpl$State ENDING>;
if v != v goto label;
label:
specialinvoke v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: void checkTasks(long)>(v);
label:
return;
}
private void adjustTasks(long)
{
java.util.Iterator v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
long v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl$State v, v;
java.util.List v;
int v;
java.lang.Object v;
boolean v, v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v := @parameter: long;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: boolean enableFailureCheck>;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: int getFreeNodeCount()>();
if v != 0 goto label;
specialinvoke v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: void checkForFailure(long)>(v);
label:
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: org.apache.drill.yarn.appMaster.ClusterControllerImpl$State state>;
v = <org.apache.drill.yarn.appMaster.ClusterControllerImpl$State: org.apache.drill.yarn.appMaster.ClusterControllerImpl$State LIVE>;
if v == v goto label;
return;
label:
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.util.List prioritizedGroups>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
interfaceinvoke v.<org.apache.drill.yarn.appMaster.SchedulerStateActions: void adjustTasks()>();
goto label;
label:
return;
}
public int getFreeNodeCount()
{
java.util.Iterator v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
org.apache.drill.yarn.appMaster.NodeInventory v;
java.util.List v;
int v, v, v;
java.lang.Object v;
boolean v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: org.apache.drill.yarn.appMaster.NodeInventory nodeInventory>;
v = virtualinvoke v.<org.apache.drill.yarn.appMaster.NodeInventory: int getFreeNodeCount()>();
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.util.List prioritizedGroups>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<org.apache.drill.yarn.appMaster.SchedulerStateActions: int getRequestCount()>();
v = v - v;
goto label;
label:
v = staticinvoke <java.lang.Math: int max(int,int)>(0, v);
return v;
}
private void checkForFailure(long)
{
java.util.Iterator v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
long v, v, v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl$State v;
java.util.List v;
byte v;
int v, v;
java.lang.Object v;
org.apache.commons.logging.Log v;
boolean v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v := @parameter: long;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: long lastFailureCheckTime>;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: int failureCheckPeriodMs>;
v = v + v;
v = v cmp v;
if v <= 0 goto label;
return;
label:
v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: long lastFailureCheckTime> = v;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.util.List prioritizedGroups>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<org.apache.drill.yarn.appMaster.SchedulerStateActions: int getTaskCount()>();
if v <= 0 goto label;
return;
label:
v = <org.apache.drill.yarn.appMaster.ClusterControllerImpl: org.apache.commons.logging.Log LOG>;
interfaceinvoke v.<org.apache.commons.logging.Log: void error(java.lang.Object)>("Application failure: no tasks are running and no nodes are available -- exiting.");
v = <org.apache.drill.yarn.appMaster.ClusterControllerImpl$State: org.apache.drill.yarn.appMaster.ClusterControllerImpl$State FAILED>;
specialinvoke v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: void terminate(org.apache.drill.yarn.appMaster.ClusterControllerImpl$State)>(v);
return;
}
private void checkTasks(long)
{
java.util.Iterator v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
long v, v, v;
java.util.List v;
byte v;
org.apache.drill.yarn.appMaster.EventContext v;
int v;
java.lang.Object v;
boolean v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v := @parameter: long;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: long lastTaskCheckTime>;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: int taskCheckPeriodMs>;
v = v + v;
v = v cmp v;
if v <= 0 goto label;
return;
label:
v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: long lastTaskCheckTime> = v;
v = new org.apache.drill.yarn.appMaster.EventContext;
specialinvoke v.<org.apache.drill.yarn.appMaster.EventContext: void <init>(org.apache.drill.yarn.appMaster.ClusterControllerImpl)>(v);
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.util.List prioritizedGroups>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
virtualinvoke v.<org.apache.drill.yarn.appMaster.EventContext: void setGroup(org.apache.drill.yarn.appMaster.SchedulerStateActions)>(v);
interfaceinvoke v.<org.apache.drill.yarn.appMaster.SchedulerStateActions: void checkTasks(org.apache.drill.yarn.appMaster.EventContext,long)>(v, v);
goto label;
label:
return;
}
public void updateRMStatus()
{
byte v;
int v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
long v, v, v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: long nextResourcePollTime>;
v = v cmp v;
if v <= 0 goto label;
return;
label:
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: int configPollPeriod>;
v = v + v;
v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: long nextResourcePollTime> = v;
return;
}
private void requestContainers()
{
java.util.Iterator v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
java.util.List v;
org.apache.drill.yarn.appMaster.EventContext v;
int v;
java.lang.Object v;
boolean v, v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v = new org.apache.drill.yarn.appMaster.EventContext;
specialinvoke v.<org.apache.drill.yarn.appMaster.EventContext: void <init>(org.apache.drill.yarn.appMaster.ClusterControllerImpl)>(v);
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.util.List prioritizedGroups>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
virtualinvoke v.<org.apache.drill.yarn.appMaster.EventContext: void setGroup(org.apache.drill.yarn.appMaster.SchedulerStateActions)>(v);
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: int maxRequestsPerTick>;
v = interfaceinvoke v.<org.apache.drill.yarn.appMaster.SchedulerStateActions: boolean requestContainers(org.apache.drill.yarn.appMaster.EventContext,int)>(v, v);
if v == 0 goto label;
label:
return;
}
public synchronized void containersAllocated(java.util.List)
{
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
int v, v, v;
java.lang.String v, v, v, v, v;
boolean v, v, v;
org.apache.drill.yarn.appMaster.AMYarnFacade v;
org.apache.hadoop.yarn.api.records.Priority v;
java.util.Iterator v;
org.apache.hadoop.yarn.api.records.NodeId v;
java.util.Set v, v;
org.apache.hadoop.yarn.api.records.ContainerId v, v;
org.apache.drill.yarn.appMaster.NodeInventory v;
java.util.List v, v, v;
org.apache.drill.yarn.appMaster.EventContext v;
java.lang.Object v, v;
org.apache.commons.logging.Log v, v;
org.apache.drill.yarn.appMaster.SchedulerStateImpl v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v := @parameter: java.util.List;
v = new org.apache.drill.yarn.appMaster.EventContext;
specialinvoke v.<org.apache.drill.yarn.appMaster.EventContext: void <init>(org.apache.drill.yarn.appMaster.ClusterControllerImpl)>(v);
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.util.Set allocatedContainers>;
v = virtualinvoke v.<org.apache.hadoop.yarn.api.records.Container: org.apache.hadoop.yarn.api.records.ContainerId getId()>();
v = interfaceinvoke v.<java.util.Set: boolean contains(java.lang.Object)>(v);
if v != 0 goto label;
v = virtualinvoke v.<org.apache.hadoop.yarn.api.records.Container: org.apache.hadoop.yarn.api.records.NodeId getNodeId()>();
v = virtualinvoke v.<org.apache.hadoop.yarn.api.records.NodeId: java.lang.String getHost()>();
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: org.apache.drill.yarn.appMaster.NodeInventory nodeInventory>;
v = virtualinvoke v.<org.apache.drill.yarn.appMaster.NodeInventory: boolean isInUse(java.lang.String)>(v);
if v == 0 goto label;
v = <org.apache.drill.yarn.appMaster.ClusterControllerImpl: org.apache.commons.logging.Log LOG>;
v = staticinvoke <org.apache.drill.yarn.core.DoYUtil: java.lang.String labelContainer(org.apache.hadoop.yarn.api.records.Container)>(v);
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[])>("Host is in use, but YARN allocated a container: \u - container rejected.");
interfaceinvoke v.<org.apache.commons.logging.Log: void error(java.lang.Object)>(v);
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: org.apache.drill.yarn.appMaster.AMYarnFacade yarn>;
interfaceinvoke v.<org.apache.drill.yarn.appMaster.AMYarnFacade: void releaseContainer(org.apache.hadoop.yarn.api.records.Container)>(v);
goto label;
label:
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.util.Set allocatedContainers>;
v = virtualinvoke v.<org.apache.hadoop.yarn.api.records.Container: org.apache.hadoop.yarn.api.records.ContainerId getId()>();
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.hadoop.yarn.api.records.Container: org.apache.hadoop.yarn.api.records.Priority getPriority()>();
v = virtualinvoke v.<org.apache.hadoop.yarn.api.records.Priority: int getPriority()>();
v = v - 1;
if v < 0 goto label;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.util.List prioritizedGroups>;
v = interfaceinvoke v.<java.util.List: int size()>();
if v <= v goto label;
label:
v = <org.apache.drill.yarn.appMaster.ClusterControllerImpl: org.apache.commons.logging.Log LOG>;
v = staticinvoke <org.apache.drill.yarn.core.DoYUtil: java.lang.String labelContainer(org.apache.hadoop.yarn.api.records.Container)>(v);
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[])>("Container allocated with unknown priority \u0001");
interfaceinvoke v.<org.apache.commons.logging.Log: void error(java.lang.Object)>(v);
goto label;
label:
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.util.List prioritizedGroups>;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(v);
virtualinvoke v.<org.apache.drill.yarn.appMaster.EventContext: void setGroup(org.apache.drill.yarn.appMaster.SchedulerStateActions)>(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 containerAllocated(org.apache.drill.yarn.appMaster.EventContext,org.apache.hadoop.yarn.api.records.Container)>(v, v);
goto label;
label:
return;
}
public synchronized void containerStarted(org.apache.hadoop.yarn.api.records.ContainerId)
{
org.apache.drill.yarn.appMaster.Task v;
org.apache.drill.yarn.appMaster.EventContext v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
org.apache.commons.logging.Log v;
java.lang.String v;
org.apache.drill.yarn.appMaster.TaskState v;
org.apache.hadoop.yarn.api.records.ContainerId v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v := @parameter: org.apache.hadoop.yarn.api.records.ContainerId;
v = specialinvoke v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: org.apache.drill.yarn.appMaster.Task getTask(org.apache.hadoop.yarn.api.records.ContainerId)>(v);
if v != null goto label;
return;
label:
v = new org.apache.drill.yarn.appMaster.EventContext;
specialinvoke v.<org.apache.drill.yarn.appMaster.EventContext: void <init>(org.apache.drill.yarn.appMaster.ClusterControllerImpl,org.apache.drill.yarn.appMaster.Task)>(v, v);
v = virtualinvoke v.<org.apache.drill.yarn.appMaster.EventContext: org.apache.drill.yarn.appMaster.TaskState getState()>();
virtualinvoke v.<org.apache.drill.yarn.appMaster.TaskState: void containerStarted(org.apache.drill.yarn.appMaster.EventContext)>(v);
v = <org.apache.drill.yarn.appMaster.ClusterControllerImpl: org.apache.commons.logging.Log LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.hadoop.yarn.api.records.ContainerId)>(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[])>("Container started: \u0001");
interfaceinvoke v.<org.apache.commons.logging.Log: void trace(java.lang.Object)>(v);
return;
}
public synchronized void taskStartFailed(org.apache.hadoop.yarn.api.records.ContainerId, java.lang.Throwable)
{
java.lang.Throwable v;
org.apache.drill.yarn.appMaster.Task v;
org.apache.drill.yarn.appMaster.EventContext v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
org.apache.drill.yarn.appMaster.TaskState v;
org.apache.hadoop.yarn.api.records.ContainerId v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v := @parameter: org.apache.hadoop.yarn.api.records.ContainerId;
v := @parameter: java.lang.Throwable;
v = specialinvoke v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: org.apache.drill.yarn.appMaster.Task getTask(org.apache.hadoop.yarn.api.records.ContainerId)>(v);
if v != null goto label;
return;
label:
v = new org.apache.drill.yarn.appMaster.EventContext;
specialinvoke v.<org.apache.drill.yarn.appMaster.EventContext: void <init>(org.apache.drill.yarn.appMaster.ClusterControllerImpl,org.apache.drill.yarn.appMaster.Task)>(v, v);
v = virtualinvoke v.<org.apache.drill.yarn.appMaster.EventContext: org.apache.drill.yarn.appMaster.TaskState getState()>();
virtualinvoke v.<org.apache.drill.yarn.appMaster.TaskState: void launchFailed(org.apache.drill.yarn.appMaster.EventContext,java.lang.Throwable)>(v, v);
return;
}
private org.apache.drill.yarn.appMaster.Task getTask(org.apache.hadoop.yarn.api.records.ContainerId)
{
java.util.Map v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
java.lang.Object v;
org.apache.hadoop.yarn.api.records.ContainerId v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v := @parameter: org.apache.hadoop.yarn.api.records.ContainerId;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.util.Map activeContainers>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
return v;
}
public synchronized void containerStopped(org.apache.hadoop.yarn.api.records.ContainerId)
{
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
org.apache.hadoop.yarn.api.records.ContainerId v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v := @parameter: org.apache.hadoop.yarn.api.records.ContainerId;
return;
}
public synchronized void containersCompleted(java.util.List)
{
java.util.Iterator v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
org.apache.drill.yarn.appMaster.TaskState v;
org.apache.hadoop.yarn.api.records.ContainerId v, v;
java.util.List v;
org.apache.drill.yarn.appMaster.Task v;
org.apache.drill.yarn.appMaster.EventContext v;
java.lang.Object v;
org.apache.commons.logging.Log v;
java.lang.String v;
boolean v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v := @parameter: java.util.List;
v = new org.apache.drill.yarn.appMaster.EventContext;
specialinvoke v.<org.apache.drill.yarn.appMaster.EventContext: void <init>(org.apache.drill.yarn.appMaster.ClusterControllerImpl)>(v);
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<org.apache.hadoop.yarn.api.records.ContainerStatus: org.apache.hadoop.yarn.api.records.ContainerId getContainerId()>();
v = specialinvoke v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: org.apache.drill.yarn.appMaster.Task getTask(org.apache.hadoop.yarn.api.records.ContainerId)>(v);
if v != null goto label;
v = <org.apache.drill.yarn.appMaster.ClusterControllerImpl: org.apache.commons.logging.Log LOG>;
v = virtualinvoke v.<org.apache.hadoop.yarn.api.records.ContainerStatus: org.apache.hadoop.yarn.api.records.ContainerId getContainerId()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.hadoop.yarn.api.records.ContainerId)>(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[])>("Container completed but no associated task state: \u0001");
interfaceinvoke v.<org.apache.commons.logging.Log: void warn(java.lang.Object)>(v);
goto label;
label:
virtualinvoke v.<org.apache.drill.yarn.appMaster.EventContext: void setTask(org.apache.drill.yarn.appMaster.Task)>(v);
v = virtualinvoke v.<org.apache.drill.yarn.appMaster.EventContext: org.apache.drill.yarn.appMaster.TaskState getState()>();
virtualinvoke v.<org.apache.drill.yarn.appMaster.TaskState: void containerCompleted(org.apache.drill.yarn.appMaster.EventContext,org.apache.hadoop.yarn.api.records.ContainerStatus)>(v, v);
goto label;
label:
specialinvoke v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: void checkStatus()>();
return;
}
public synchronized float getProgress()
{
java.util.Iterator v;
java.util.Collection v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
int[] v;
java.util.Map v;
org.apache.drill.yarn.appMaster.Scheduler v;
int v, v, v, v;
float v;
java.lang.Object v;
boolean v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v = 0;
v = 0;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.util.Map taskPools>;
v = interfaceinvoke v.<java.util.Map: java.util.Collection values()>();
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<org.apache.drill.yarn.appMaster.SchedulerStateActions: org.apache.drill.yarn.appMaster.Scheduler getScheduler()>();
v = interfaceinvoke v.<org.apache.drill.yarn.appMaster.Scheduler: int[] getProgress()>();
v = v[0];
v = v + v;
v = v[1];
v = v + v;
goto label;
label:
if v != 0 goto label;
return 1.0F;
label:
v = v / v;
return v;
}
public synchronized void stopTaskFailed(org.apache.hadoop.yarn.api.records.ContainerId, java.lang.Throwable)
{
java.lang.Throwable v;
org.apache.drill.yarn.appMaster.Task v;
org.apache.drill.yarn.appMaster.EventContext v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
org.apache.drill.yarn.appMaster.TaskState v;
org.apache.hadoop.yarn.api.records.ContainerId v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v := @parameter: org.apache.hadoop.yarn.api.records.ContainerId;
v := @parameter: java.lang.Throwable;
v = specialinvoke v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: org.apache.drill.yarn.appMaster.Task getTask(org.apache.hadoop.yarn.api.records.ContainerId)>(v);
if v != null goto label;
return;
label:
v = new org.apache.drill.yarn.appMaster.EventContext;
specialinvoke v.<org.apache.drill.yarn.appMaster.EventContext: void <init>(org.apache.drill.yarn.appMaster.ClusterControllerImpl,org.apache.drill.yarn.appMaster.Task)>(v, v);
v = virtualinvoke v.<org.apache.drill.yarn.appMaster.EventContext: org.apache.drill.yarn.appMaster.TaskState getState()>();
virtualinvoke v.<org.apache.drill.yarn.appMaster.TaskState: void stopTaskFailed(org.apache.drill.yarn.appMaster.EventContext,java.lang.Throwable)>(v, v);
return;
}
public synchronized void resizeDelta(int)
{
java.util.List v;
org.apache.drill.yarn.appMaster.Scheduler v;
int v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
java.lang.Object v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v := @parameter: int;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.util.List prioritizedGroups>;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = interfaceinvoke v.<org.apache.drill.yarn.appMaster.SchedulerStateActions: org.apache.drill.yarn.appMaster.Scheduler getScheduler()>();
interfaceinvoke v.<org.apache.drill.yarn.appMaster.Scheduler: void change(int)>(v);
return;
}
public synchronized int resizeTo(int)
{
java.util.List v;
org.apache.drill.yarn.appMaster.Scheduler v;
int v, v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
java.lang.Object v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v := @parameter: int;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.util.List prioritizedGroups>;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = interfaceinvoke v.<org.apache.drill.yarn.appMaster.SchedulerStateActions: org.apache.drill.yarn.appMaster.Scheduler getScheduler()>();
v = interfaceinvoke v.<org.apache.drill.yarn.appMaster.Scheduler: int resize(int)>(v);
return v;
}
public synchronized void shutDown()
{
java.util.Iterator v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl$State v;
java.util.List v;
org.apache.drill.yarn.appMaster.EventContext v;
java.lang.Object v;
org.apache.commons.logging.Log v;
boolean v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v = <org.apache.drill.yarn.appMaster.ClusterControllerImpl: org.apache.commons.logging.Log LOG>;
interfaceinvoke v.<org.apache.commons.logging.Log: void info(java.lang.Object)>("Shut down request received");
v = <org.apache.drill.yarn.appMaster.ClusterControllerImpl$State: org.apache.drill.yarn.appMaster.ClusterControllerImpl$State ENDING>;
v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: org.apache.drill.yarn.appMaster.ClusterControllerImpl$State state> = v;
v = new org.apache.drill.yarn.appMaster.EventContext;
specialinvoke v.<org.apache.drill.yarn.appMaster.EventContext: void <init>(org.apache.drill.yarn.appMaster.ClusterControllerImpl)>(v);
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.util.List prioritizedGroups>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
interfaceinvoke v.<org.apache.drill.yarn.appMaster.SchedulerStateActions: void shutDown(org.apache.drill.yarn.appMaster.EventContext)>(v);
goto label;
label:
specialinvoke v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: void checkStatus()>();
return;
}
public boolean waitForCompletion()
{
java.lang.Throwable v;
java.lang.InterruptedException v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
java.lang.Object v, v;
org.apache.commons.logging.Log v;
boolean v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
specialinvoke v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: void start()>();
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.lang.Object completionMutex>;
entermonitor v;
label:
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.lang.Object completionMutex>;
virtualinvoke v.<java.lang.Object: void wait()>();
v = <org.apache.drill.yarn.appMaster.ClusterControllerImpl: org.apache.commons.logging.Log LOG>;
interfaceinvoke v.<org.apache.commons.logging.Log: void info(java.lang.Object)>("Controller shut down completed");
label:
goto label;
label:
v := @caughtexception;
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v = virtualinvoke v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: boolean succeeded()>();
return v;
catch java.lang.InterruptedException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
private void start()
{
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
specialinvoke v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: void yarnReport()>();
return;
}
private void yarnReport()
{
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
int v, v;
org.apache.hadoop.yarn.api.records.Resource v;
java.lang.String v, v, v, v, v, v, v;
java.util.EnumSet v;
boolean v;
org.apache.drill.yarn.appMaster.AMYarnFacade v;
java.util.Iterator v;
org.apache.hadoop.yarn.api.protocolrecords.RegisterApplicationMasterResponse v;
java.lang.Object v;
java.lang.StringBuilder v;
org.apache.commons.logging.Log v, v, v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: org.apache.drill.yarn.appMaster.AMYarnFacade yarn>;
v = interfaceinvoke v.<org.apache.drill.yarn.appMaster.AMYarnFacade: org.apache.hadoop.yarn.api.protocolrecords.RegisterApplicationMasterResponse getRegistrationResponse()>();
v = <org.apache.drill.yarn.appMaster.ClusterControllerImpl: org.apache.commons.logging.Log LOG>;
v = virtualinvoke v.<org.apache.hadoop.yarn.api.protocolrecords.RegisterApplicationMasterResponse: java.lang.String getQueue()>();
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[])>("YARN queue: \u0001");
interfaceinvoke v.<org.apache.commons.logging.Log: void info(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.hadoop.yarn.api.protocolrecords.RegisterApplicationMasterResponse: org.apache.hadoop.yarn.api.records.Resource getMaximumResourceCapability()>();
v = <org.apache.drill.yarn.appMaster.ClusterControllerImpl: org.apache.commons.logging.Log LOG>;
v = virtualinvoke v.<org.apache.hadoop.yarn.api.records.Resource: int getMemory()>();
v = virtualinvoke v.<org.apache.hadoop.yarn.api.records.Resource: int getVirtualCores()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int,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[])>("YARN max resource: \u MB, \u cores");
interfaceinvoke v.<org.apache.commons.logging.Log: void info(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.hadoop.yarn.api.protocolrecords.RegisterApplicationMasterResponse: java.util.EnumSet getSchedulerResourceTypes()>();
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
v = "";
v = virtualinvoke v.<java.util.EnumSet: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.hadoop.yarn.proto.YarnServiceProtos$SchedulerResourceTypes: java.lang.String toString()>();
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = ", ";
goto label;
label:
v = <org.apache.drill.yarn.appMaster.ClusterControllerImpl: org.apache.commons.logging.Log LOG>;
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
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[])>("YARN scheduler resource types: \u0001");
interfaceinvoke v.<org.apache.commons.logging.Log: void info(java.lang.Object)>(v);
return;
}
private void checkStatus()
{
java.util.Iterator v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl$State v, v, v;
java.util.List v;
java.lang.Object v;
boolean v, v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: org.apache.drill.yarn.appMaster.ClusterControllerImpl$State state>;
v = <org.apache.drill.yarn.appMaster.ClusterControllerImpl$State: org.apache.drill.yarn.appMaster.ClusterControllerImpl$State ENDING>;
if v == v goto label;
return;
label:
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.util.List prioritizedGroups>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<org.apache.drill.yarn.appMaster.SchedulerStateActions: boolean isDone()>();
if v != 0 goto label;
return;
label:
v = <org.apache.drill.yarn.appMaster.ClusterControllerImpl$State: org.apache.drill.yarn.appMaster.ClusterControllerImpl$State ENDED>;
specialinvoke v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: void terminate(org.apache.drill.yarn.appMaster.ClusterControllerImpl$State)>(v);
return;
}
private void terminate(org.apache.drill.yarn.appMaster.ClusterControllerImpl$State)
{
java.lang.Throwable v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl$State v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
java.lang.Object v, v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v := @parameter: org.apache.drill.yarn.appMaster.ClusterControllerImpl$State;
v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: org.apache.drill.yarn.appMaster.ClusterControllerImpl$State state> = v;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.lang.Object completionMutex>;
entermonitor v;
label:
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.lang.Object completionMutex>;
virtualinvoke v.<java.lang.Object: void notify()>();
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public boolean isLive()
{
org.apache.drill.yarn.appMaster.ClusterControllerImpl$State v, v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
boolean v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: org.apache.drill.yarn.appMaster.ClusterControllerImpl$State state>;
v = <org.apache.drill.yarn.appMaster.ClusterControllerImpl$State: org.apache.drill.yarn.appMaster.ClusterControllerImpl$State LIVE>;
if v != v goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public boolean succeeded()
{
org.apache.drill.yarn.appMaster.ClusterControllerImpl$State v, v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
boolean v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: org.apache.drill.yarn.appMaster.ClusterControllerImpl$State state>;
v = <org.apache.drill.yarn.appMaster.ClusterControllerImpl$State: org.apache.drill.yarn.appMaster.ClusterControllerImpl$State ENDED>;
if v != v goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public void containerAllocated(org.apache.drill.yarn.appMaster.Task)
{
org.apache.drill.yarn.appMaster.Task v;
java.util.Map v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
org.apache.hadoop.yarn.api.records.ContainerId v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v := @parameter: org.apache.drill.yarn.appMaster.Task;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.util.Map activeContainers>;
v = virtualinvoke v.<org.apache.drill.yarn.appMaster.Task: org.apache.hadoop.yarn.api.records.ContainerId getContainerId()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
return;
}
public org.apache.drill.yarn.appMaster.AMYarnFacade getYarn()
{
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
org.apache.drill.yarn.appMaster.AMYarnFacade v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: org.apache.drill.yarn.appMaster.AMYarnFacade yarn>;
return v;
}
public void containerReleased(org.apache.drill.yarn.appMaster.Task)
{
org.apache.drill.yarn.appMaster.Task v;
java.util.Map v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
org.apache.hadoop.yarn.api.records.ContainerId v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v := @parameter: org.apache.drill.yarn.appMaster.Task;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.util.Map activeContainers>;
v = virtualinvoke v.<org.apache.drill.yarn.appMaster.Task: org.apache.hadoop.yarn.api.records.ContainerId getContainerId()>();
interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>(v);
return;
}
public void taskEnded(org.apache.drill.yarn.appMaster.Task)
{
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
java.util.List v;
org.apache.drill.yarn.appMaster.Task v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v := @parameter: org.apache.drill.yarn.appMaster.Task;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.util.List completedTasks>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
return;
}
public void taskRetried(org.apache.drill.yarn.appMaster.Task)
{
java.util.List v;
org.apache.drill.yarn.appMaster.Task v, v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
org.apache.drill.yarn.appMaster.Task$Disposition v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v := @parameter: org.apache.drill.yarn.appMaster.Task;
v = virtualinvoke v.<org.apache.drill.yarn.appMaster.Task: org.apache.drill.yarn.appMaster.Task copy()>();
v = <org.apache.drill.yarn.appMaster.Task$Disposition: org.apache.drill.yarn.appMaster.Task$Disposition RETRIED>;
v.<org.apache.drill.yarn.appMaster.Task: org.apache.drill.yarn.appMaster.Task$Disposition disposition> = v;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.util.List completedTasks>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
return;
}
public void taskGroupCompleted(org.apache.drill.yarn.appMaster.SchedulerStateActions)
{
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
org.apache.drill.yarn.appMaster.SchedulerStateActions v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v := @parameter: org.apache.drill.yarn.appMaster.SchedulerStateActions;
specialinvoke v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: void checkStatus()>();
return;
}
public int getMaxRetries()
{
int v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: int maxRetries>;
return v;
}
public int getStopTimeoutMs()
{
int v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: int stopTimoutMs>;
return v;
}
public synchronized void reserveHost(java.lang.String)
{
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
java.lang.String v;
org.apache.drill.yarn.appMaster.NodeInventory v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v := @parameter: java.lang.String;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: org.apache.drill.yarn.appMaster.NodeInventory nodeInventory>;
virtualinvoke v.<org.apache.drill.yarn.appMaster.NodeInventory: void reserve(java.lang.String)>(v);
return;
}
public synchronized void releaseHost(java.lang.String)
{
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
java.lang.String v;
org.apache.drill.yarn.appMaster.NodeInventory v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v := @parameter: java.lang.String;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: org.apache.drill.yarn.appMaster.NodeInventory nodeInventory>;
virtualinvoke v.<org.apache.drill.yarn.appMaster.NodeInventory: void release(java.lang.String)>(v);
return;
}
public org.apache.drill.yarn.appMaster.NodeInventory getNodeInventory()
{
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
org.apache.drill.yarn.appMaster.NodeInventory v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: org.apache.drill.yarn.appMaster.NodeInventory nodeInventory>;
return v;
}
public void setProperty(java.lang.String, java.lang.Object)
{
java.util.Map v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
java.lang.Object v;
java.lang.String v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Object;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.util.Map properties>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
return;
}
public java.lang.Object getProperty(java.lang.String)
{
java.util.Map v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
java.lang.Object v;
java.lang.String v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v := @parameter: java.lang.String;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.util.Map properties>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
return v;
}
public void registerLifecycleListener(org.apache.drill.yarn.appMaster.TaskLifecycleListener)
{
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
java.util.List v;
org.apache.drill.yarn.appMaster.TaskLifecycleListener v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v := @parameter: org.apache.drill.yarn.appMaster.TaskLifecycleListener;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.util.List lifecycleListeners>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
return;
}
public void fireLifecycleChange(org.apache.drill.yarn.appMaster.TaskLifecycleListener$Event, org.apache.drill.yarn.appMaster.EventContext)
{
org.apache.drill.yarn.appMaster.TaskLifecycleListener$Event v;
java.util.List v;
java.util.Iterator v;
org.apache.drill.yarn.appMaster.EventContext v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
java.lang.Object v;
boolean v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v := @parameter: org.apache.drill.yarn.appMaster.TaskLifecycleListener$Event;
v := @parameter: org.apache.drill.yarn.appMaster.EventContext;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.util.List lifecycleListeners>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
interfaceinvoke v.<org.apache.drill.yarn.appMaster.TaskLifecycleListener: void stateChange(org.apache.drill.yarn.appMaster.TaskLifecycleListener$Event,org.apache.drill.yarn.appMaster.EventContext)>(v, v);
goto label;
label:
return;
}
public void setMaxRetries(int)
{
int v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v := @parameter: int;
v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: int maxRetries> = v;
return;
}
public int getTargetCount()
{
java.util.Iterator v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
java.util.List v;
org.apache.drill.yarn.appMaster.Scheduler v;
int v, v;
java.lang.Object v;
boolean v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v = 0;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.util.List prioritizedGroups>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<org.apache.drill.yarn.appMaster.SchedulerStateActions: org.apache.drill.yarn.appMaster.Scheduler getScheduler()>();
v = interfaceinvoke v.<org.apache.drill.yarn.appMaster.Scheduler: int getTarget()>();
v = v + v;
goto label;
label:
return v;
}
public org.apache.drill.yarn.appMaster.ClusterControllerImpl$State getState()
{
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl$State v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: org.apache.drill.yarn.appMaster.ClusterControllerImpl$State state>;
return v;
}
public synchronized void visit(org.apache.drill.yarn.appMaster.ControllerVisitor)
{
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
org.apache.drill.yarn.appMaster.ControllerVisitor v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v := @parameter: org.apache.drill.yarn.appMaster.ControllerVisitor;
interfaceinvoke v.<org.apache.drill.yarn.appMaster.ControllerVisitor: void visit(org.apache.drill.yarn.appMaster.ClusterController)>(v);
return;
}
public java.util.List getPools()
{
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
java.util.List v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.util.List prioritizedGroups>;
return v;
}
public synchronized void visitTasks(org.apache.drill.yarn.appMaster.TaskVisitor)
{
java.util.List v;
java.util.Iterator v;
org.apache.drill.yarn.appMaster.TaskVisitor v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
java.lang.Object v;
boolean v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v := @parameter: org.apache.drill.yarn.appMaster.TaskVisitor;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.util.List prioritizedGroups>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
interfaceinvoke v.<org.apache.drill.yarn.appMaster.SchedulerStateActions: void visitTaskModels(org.apache.drill.yarn.appMaster.TaskVisitor)>(v);
goto label;
label:
return;
}
public java.util.List getHistory()
{
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
java.util.List v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.util.List completedTasks>;
return v;
}
public boolean isTaskLive(int)
{
java.util.Iterator v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
java.util.List v;
org.apache.drill.yarn.appMaster.Task v;
int v;
java.lang.Object v;
boolean v, v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v := @parameter: int;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.util.List prioritizedGroups>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<org.apache.drill.yarn.appMaster.SchedulerStateActions: org.apache.drill.yarn.appMaster.Task getTask(int)>(v);
if v == null goto label;
v = virtualinvoke v.<org.apache.drill.yarn.appMaster.Task: boolean isLive()>();
return v;
label:
return 0;
}
public synchronized boolean cancelTask(int)
{
java.util.Iterator v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
java.util.List v;
org.apache.drill.yarn.appMaster.Task v;
org.apache.drill.yarn.appMaster.Scheduler v;
int v, v;
java.lang.Object v;
org.apache.commons.logging.Log v;
java.lang.String v;
boolean v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v := @parameter: int;
v = v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: java.util.List prioritizedGroups>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<org.apache.drill.yarn.appMaster.SchedulerStateActions: org.apache.drill.yarn.appMaster.Task getTask(int)>(v);
if v == null goto label;
interfaceinvoke v.<org.apache.drill.yarn.appMaster.SchedulerStateActions: void cancel(org.apache.drill.yarn.appMaster.Task)>(v);
v = interfaceinvoke v.<org.apache.drill.yarn.appMaster.SchedulerStateActions: org.apache.drill.yarn.appMaster.Scheduler getScheduler()>();
v = (int) -1;
interfaceinvoke v.<org.apache.drill.yarn.appMaster.Scheduler: void change(int)>(v);
return 1;
label:
v = <org.apache.drill.yarn.appMaster.ClusterControllerImpl: org.apache.commons.logging.Log LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(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[])>("Requested to cancel task, but no task found: \u0001");
interfaceinvoke v.<org.apache.commons.logging.Log: void warn(java.lang.Object)>(v);
return 0;
}
public synchronized void completionAck(org.apache.drill.yarn.appMaster.Task, java.lang.String)
{
org.apache.drill.yarn.appMaster.Task v;
org.apache.drill.yarn.appMaster.EventContext v;
java.util.Map v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
java.lang.String v;
org.apache.drill.yarn.appMaster.TaskState v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v := @parameter: org.apache.drill.yarn.appMaster.Task;
v := @parameter: java.lang.String;
v = new org.apache.drill.yarn.appMaster.EventContext;
specialinvoke v.<org.apache.drill.yarn.appMaster.EventContext: void <init>(org.apache.drill.yarn.appMaster.ClusterControllerImpl)>(v);
virtualinvoke v.<org.apache.drill.yarn.appMaster.EventContext: void setTask(org.apache.drill.yarn.appMaster.Task)>(v);
v = virtualinvoke v.<org.apache.drill.yarn.appMaster.EventContext: org.apache.drill.yarn.appMaster.TaskState getState()>();
virtualinvoke v.<org.apache.drill.yarn.appMaster.TaskState: void completionAck(org.apache.drill.yarn.appMaster.EventContext)>(v);
if v == null goto label;
v = v.<org.apache.drill.yarn.appMaster.Task: java.util.Map properties>;
interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>(v);
label:
return;
}
public synchronized void startAck(org.apache.drill.yarn.appMaster.Task, java.lang.String, java.lang.Object)
{
org.apache.drill.yarn.appMaster.Task v;
org.apache.drill.yarn.appMaster.EventContext v;
java.util.Map v;
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
java.lang.Object v;
java.lang.String v;
org.apache.drill.yarn.appMaster.TaskState v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v := @parameter: org.apache.drill.yarn.appMaster.Task;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Object;
if v == null goto label;
if v == null goto label;
v = v.<org.apache.drill.yarn.appMaster.Task: java.util.Map properties>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
v = new org.apache.drill.yarn.appMaster.EventContext;
specialinvoke v.<org.apache.drill.yarn.appMaster.EventContext: void <init>(org.apache.drill.yarn.appMaster.ClusterControllerImpl)>(v);
virtualinvoke v.<org.apache.drill.yarn.appMaster.EventContext: void setTask(org.apache.drill.yarn.appMaster.Task)>(v);
v = virtualinvoke v.<org.apache.drill.yarn.appMaster.EventContext: org.apache.drill.yarn.appMaster.TaskState getState()>();
virtualinvoke v.<org.apache.drill.yarn.appMaster.TaskState: void startAck(org.apache.drill.yarn.appMaster.EventContext)>(v);
return;
}
public boolean supportsDiskResource()
{
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
org.apache.drill.yarn.appMaster.AMYarnFacade v;
boolean v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
v = virtualinvoke v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: org.apache.drill.yarn.appMaster.AMYarnFacade getYarn()>();
v = interfaceinvoke v.<org.apache.drill.yarn.appMaster.AMYarnFacade: boolean supportsDiskResource()>();
return v;
}
public void registryDown()
{
org.apache.drill.yarn.appMaster.ClusterControllerImpl v;
v := @this: org.apache.drill.yarn.appMaster.ClusterControllerImpl;
virtualinvoke v.<org.apache.drill.yarn.appMaster.ClusterControllerImpl: void shutDown()>();
return;
}
static void <clinit>()
{
java.lang.Class v;
org.apache.commons.logging.Log v;
boolean v, v;
v = class "Lorg/apache/drill/yarn/appMaster/ClusterControllerImpl;";
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.ClusterControllerImpl: 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/ClusterControllerImpl;");
<org.apache.drill.yarn.appMaster.ClusterControllerImpl: org.apache.commons.logging.Log LOG> = v;
return;
}
}