public class org.apache.drill.yarn.appMaster.DrillControllerFactory extends java.lang.Object implements org.apache.drill.yarn.appMaster.ControllerFactory
{
private static final org.apache.commons.logging.Log LOG;
private com.typesafe.config.Config config;
private java.lang.String drillArchivePath;
private java.lang.String siteArchivePath;
private boolean localized;
public void <init>()
{
com.typesafe.config.Config v;
org.apache.drill.yarn.appMaster.DrillControllerFactory v;
v := @this: org.apache.drill.yarn.appMaster.DrillControllerFactory;
specialinvoke v.<java.lang.Object: void <init>()>();
v = staticinvoke <org.apache.drill.yarn.core.DrillOnYarnConfig: com.typesafe.config.Config config()>();
v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: com.typesafe.config.Config config> = v;
return;
}
public org.apache.drill.yarn.appMaster.Dispatcher build() throws org.apache.drill.yarn.appMaster.ControllerFactory$ControllerFactoryException
{
org.apache.drill.yarn.appMaster.TaskSpec v;
java.util.Map v;
boolean v, v;
org.apache.drill.yarn.appMaster.DrillbitScheduler v;
java.lang.Exception v;
org.apache.drill.yarn.appMaster.AMYarnFacadeImpl v;
org.apache.drill.yarn.core.ClusterDef$ClusterGroup v;
org.apache.drill.yarn.appMaster.DrillControllerFactory v;
org.apache.drill.yarn.appMaster.ControllerFactory$ControllerFactoryException v;
org.apache.drill.yarn.appMaster.Dispatcher v;
int v, v, v, v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.drill.yarn.appMaster.ClusterController v, v, v;
com.typesafe.config.Config v, v, v, v, v, v, v, v, v, v, v;
org.apache.commons.logging.Log v;
v := @this: org.apache.drill.yarn.appMaster.DrillControllerFactory;
v = <org.apache.drill.yarn.appMaster.DrillControllerFactory: org.apache.commons.logging.Log LOG>;
v = v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: com.typesafe.config.Config config>;
v = <org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String APP_NAME>;
v = interfaceinvoke v.<com.typesafe.config.Config: java.lang.String getString(java.lang.String)>(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[])>("Initializing AM for \u0001");
interfaceinvoke v.<org.apache.commons.logging.Log: void info(java.lang.Object)>(v);
label:
v = specialinvoke v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: java.util.Map prepareResources()>();
v = specialinvoke v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: org.apache.drill.yarn.appMaster.TaskSpec buildDrillTaskSpec(java.util.Map)>(v);
v = v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: com.typesafe.config.Config config>;
v = <org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String AM_TICK_PERIOD_MS>;
v = interfaceinvoke v.<com.typesafe.config.Config: int getInt(java.lang.String)>(v);
v = new org.apache.drill.yarn.appMaster.Dispatcher;
specialinvoke v.<org.apache.drill.yarn.appMaster.Dispatcher: void <init>(int)>(v);
v = v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: com.typesafe.config.Config config>;
v = <org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String AM_POLL_PERIOD_MS>;
v = interfaceinvoke v.<com.typesafe.config.Config: int getInt(java.lang.String)>(v);
v = new org.apache.drill.yarn.appMaster.AMYarnFacadeImpl;
specialinvoke v.<org.apache.drill.yarn.appMaster.AMYarnFacadeImpl: void <init>(int)>(v);
virtualinvoke v.<org.apache.drill.yarn.appMaster.Dispatcher: void setYarn(org.apache.drill.yarn.appMaster.AMYarnFacade)>(v);
v = virtualinvoke v.<org.apache.drill.yarn.appMaster.Dispatcher: org.apache.drill.yarn.appMaster.ClusterController getController()>();
v = v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: com.typesafe.config.Config config>;
v = <org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String DRILLBIT_MAX_RETRIES>;
v = interfaceinvoke v.<com.typesafe.config.Config: int getInt(java.lang.String)>(v);
interfaceinvoke v.<org.apache.drill.yarn.appMaster.ClusterController: void setMaxRetries(int)>(v);
v = staticinvoke <org.apache.drill.yarn.core.DrillOnYarnConfig: com.typesafe.config.Config config()>();
v = <org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String DRILLBIT_REQUEST_TIMEOUT_SEC>;
v = interfaceinvoke v.<com.typesafe.config.Config: int getInt(java.lang.String)>(v);
v = staticinvoke <org.apache.drill.yarn.core.DrillOnYarnConfig: com.typesafe.config.Config config()>();
v = <org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String DRILLBIT_MAX_EXTRA_NODES>;
v = interfaceinvoke v.<com.typesafe.config.Config: int getInt(java.lang.String)>(v);
v = v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: com.typesafe.config.Config config>;
v = staticinvoke <org.apache.drill.yarn.core.ClusterDef: org.apache.drill.yarn.core.ClusterDef$ClusterGroup getCluster(com.typesafe.config.Config,int)>(v, 0);
v = new org.apache.drill.yarn.appMaster.DrillbitScheduler;
v = virtualinvoke v.<org.apache.drill.yarn.core.ClusterDef$ClusterGroup: java.lang.String getName()>();
v = virtualinvoke v.<org.apache.drill.yarn.core.ClusterDef$ClusterGroup: int getCount()>();
specialinvoke v.<org.apache.drill.yarn.appMaster.DrillbitScheduler: void <init>(java.lang.String,org.apache.drill.yarn.appMaster.TaskSpec,int,int,int)>(v, v, v, v, v);
v = virtualinvoke v.<org.apache.drill.yarn.appMaster.Dispatcher: org.apache.drill.yarn.appMaster.ClusterController getController()>();
interfaceinvoke v.<org.apache.drill.yarn.appMaster.ClusterController: void registerScheduler(org.apache.drill.yarn.appMaster.Scheduler)>(v);
virtualinvoke v.<org.apache.drill.yarn.core.ClusterDef$ClusterGroup: void modifyTaskSpec(org.apache.drill.yarn.appMaster.TaskSpec)>(v);
v = v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: com.typesafe.config.Config config>;
specialinvoke v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: void buildZooKeeper(com.typesafe.config.Config,org.apache.drill.yarn.appMaster.Dispatcher)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.drill.yarn.appMaster.ControllerFactory$ControllerFactoryException;
specialinvoke v.<org.apache.drill.yarn.appMaster.ControllerFactory$ControllerFactoryException: void <init>(java.lang.String,java.lang.Exception)>("Drill AM intitialization failed", v);
throw v;
label:
v = v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: com.typesafe.config.Config config>;
v = <org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String HTTP_PORT>;
v = interfaceinvoke v.<com.typesafe.config.Config: int getInt(java.lang.String)>(v);
virtualinvoke v.<org.apache.drill.yarn.appMaster.Dispatcher: void setHttpPort(int)>(v);
v = v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: com.typesafe.config.Config config>;
v = <org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String HTTP_ENABLED>;
v = interfaceinvoke v.<com.typesafe.config.Config: boolean getBoolean(java.lang.String)>(v);
if v == 0 goto label;
virtualinvoke v.<org.apache.drill.yarn.appMaster.Dispatcher: void setTrackingUrl(java.lang.String)>("http://<host>:<port>/redirect");
label:
v = virtualinvoke v.<org.apache.drill.yarn.appMaster.Dispatcher: org.apache.drill.yarn.appMaster.ClusterController getController()>();
v = v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: com.typesafe.config.Config config>;
v = <org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String AM_ENABLE_AUTO_SHUTDOWN>;
v = interfaceinvoke v.<com.typesafe.config.Config: boolean getBoolean(java.lang.String)>(v);
interfaceinvoke v.<org.apache.drill.yarn.appMaster.ClusterController: void enableFailureCheck(boolean)>(v);
staticinvoke <org.apache.drill.yarn.appMaster.http.AMSecurityManagerImpl: void setup()>();
return v;
catch org.apache.drill.yarn.appMaster.YarnFacadeException from label to label with label;
catch org.apache.drill.yarn.core.DoyConfigException from label to label with label;
}
private java.util.Map prepareResources() throws org.apache.drill.yarn.appMaster.YarnFacadeException
{
org.apache.drill.yarn.core.DrillOnYarnConfig v;
org.apache.drill.yarn.appMaster.DrillControllerFactory v;
java.util.HashMap v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v;
boolean v, v;
org.apache.drill.yarn.appMaster.YarnFacadeException v;
org.apache.drill.yarn.core.DfsFacade$Localizer v, v;
com.typesafe.config.Config v, v, v;
org.apache.drill.yarn.core.DfsFacade$DfsFacadeException v;
org.apache.drill.yarn.core.DfsFacade v;
org.apache.commons.logging.Log v, v;
v := @this: org.apache.drill.yarn.appMaster.DrillControllerFactory;
label:
v = new org.apache.drill.yarn.core.DfsFacade;
v = v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: com.typesafe.config.Config config>;
specialinvoke v.<org.apache.drill.yarn.core.DfsFacade: void <init>(com.typesafe.config.Config)>(v);
v = virtualinvoke v.<org.apache.drill.yarn.core.DfsFacade: boolean isLocalized()>();
v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: boolean localized> = v;
v = v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: boolean localized>;
if v != 0 goto label;
label:
return null;
label:
virtualinvoke v.<org.apache.drill.yarn.core.DfsFacade: void connect()>();
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = staticinvoke <org.apache.drill.yarn.core.DrillOnYarnConfig: org.apache.drill.yarn.core.DrillOnYarnConfig instance()>();
v = virtualinvoke v.<org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String getDrillArchiveDfsPath()>();
v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: java.lang.String drillArchivePath> = v;
v = new org.apache.drill.yarn.core.DfsFacade$Localizer;
v = v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: java.lang.String drillArchivePath>;
specialinvoke v.<org.apache.drill.yarn.core.DfsFacade$Localizer: void <init>(org.apache.drill.yarn.core.DfsFacade,java.lang.String)>(v, v);
v = v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: com.typesafe.config.Config config>;
v = <org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String DRILL_ARCHIVE_KEY>;
v = interfaceinvoke v.<com.typesafe.config.Config: java.lang.String getString(java.lang.String)>(v);
virtualinvoke v.<org.apache.drill.yarn.core.DfsFacade$Localizer: void defineResources(java.util.Map,java.lang.String)>(v, v);
v = <org.apache.drill.yarn.appMaster.DrillControllerFactory: org.apache.commons.logging.Log LOG>;
v = v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: java.lang.String drillArchivePath>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(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[])>("Localizing \u with key \"\u0001\"");
interfaceinvoke v.<org.apache.commons.logging.Log: void info(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String getSiteArchiveDfsPath()>();
v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: java.lang.String siteArchivePath> = v;
v = v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: java.lang.String siteArchivePath>;
if v == null goto label;
v = new org.apache.drill.yarn.core.DfsFacade$Localizer;
v = v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: java.lang.String siteArchivePath>;
specialinvoke v.<org.apache.drill.yarn.core.DfsFacade$Localizer: void <init>(org.apache.drill.yarn.core.DfsFacade,java.lang.String)>(v, v);
v = v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: com.typesafe.config.Config config>;
v = <org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String SITE_ARCHIVE_KEY>;
v = interfaceinvoke v.<com.typesafe.config.Config: java.lang.String getString(java.lang.String)>(v);
virtualinvoke v.<org.apache.drill.yarn.core.DfsFacade$Localizer: void defineResources(java.util.Map,java.lang.String)>(v, v);
v = <org.apache.drill.yarn.appMaster.DrillControllerFactory: org.apache.commons.logging.Log LOG>;
v = v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: java.lang.String siteArchivePath>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(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[])>("Localizing \u with key \"\u0001\"");
interfaceinvoke v.<org.apache.commons.logging.Log: void info(java.lang.Object)>(v);
label:
return v;
label:
v := @caughtexception;
v = new org.apache.drill.yarn.appMaster.YarnFacadeException;
specialinvoke v.<org.apache.drill.yarn.appMaster.YarnFacadeException: void <init>(java.lang.String,java.lang.Exception)>("Failed to get DFS status for Drill archive", v);
throw v;
catch org.apache.drill.yarn.core.DfsFacade$DfsFacadeException from label to label with label;
catch org.apache.drill.yarn.core.DfsFacade$DfsFacadeException from label to label with label;
}
private org.apache.drill.yarn.appMaster.TaskSpec buildDrillTaskSpec(java.util.Map) throws org.apache.drill.yarn.core.DoyConfigException
{
org.apache.drill.yarn.appMaster.TaskSpec v;
java.util.Map v, v, v, v, v, v;
org.apache.drill.yarn.core.ContainerRequestSpec v;
boolean v, v, v;
java.util.List v, v;
org.apache.drill.yarn.core.DrillOnYarnConfig v;
org.apache.drill.yarn.appMaster.DrillControllerFactory v;
org.apache.drill.yarn.core.LaunchSpec v;
int v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
double v;
com.typesafe.config.Config v, v, v, v, v, v, v;
org.apache.commons.logging.Log v;
v := @this: org.apache.drill.yarn.appMaster.DrillControllerFactory;
v := @parameter: java.util.Map;
v = staticinvoke <org.apache.drill.yarn.core.DrillOnYarnConfig: org.apache.drill.yarn.core.DrillOnYarnConfig instance()>();
v = new org.apache.drill.yarn.core.ContainerRequestSpec;
specialinvoke v.<org.apache.drill.yarn.core.ContainerRequestSpec: void <init>()>();
v = v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: com.typesafe.config.Config config>;
v = <org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String DRILLBIT_MEMORY>;
v = interfaceinvoke v.<com.typesafe.config.Config: int getInt(java.lang.String)>(v);
v.<org.apache.drill.yarn.core.ContainerRequestSpec: int memoryMb> = v;
v = v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: com.typesafe.config.Config config>;
v = <org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String DRILLBIT_VCORES>;
v = interfaceinvoke v.<com.typesafe.config.Config: int getInt(java.lang.String)>(v);
v.<org.apache.drill.yarn.core.ContainerRequestSpec: int vCores> = v;
v = v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: com.typesafe.config.Config config>;
v = <org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String DRILLBIT_DISKS>;
v = interfaceinvoke v.<com.typesafe.config.Config: double getDouble(java.lang.String)>(v);
v.<org.apache.drill.yarn.core.ContainerRequestSpec: double disks> = v;
v = new org.apache.drill.yarn.core.LaunchSpec;
specialinvoke v.<org.apache.drill.yarn.core.LaunchSpec: void <init>()>();
v = virtualinvoke v.<org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String getRemoteDrillHome()>();
v = v.<org.apache.drill.yarn.core.LaunchSpec: java.util.Map env>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("DRILL_HOME", v);
v = <org.apache.drill.yarn.appMaster.DrillControllerFactory: org.apache.commons.logging.Log LOG>;
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[])>("Drillbit DRILL_HOME: \u0001");
interfaceinvoke v.<org.apache.commons.logging.Log: void trace(java.lang.Object)>(v);
v = <org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String DRILLBIT_HEAP>;
virtualinvoke v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: void addIfSet(org.apache.drill.yarn.core.LaunchSpec,java.lang.String,java.lang.String)>(v, v, "DRILL_HEAP");
v = <org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String DRILLBIT_DIRECT_MEM>;
virtualinvoke v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: void addIfSet(org.apache.drill.yarn.core.LaunchSpec,java.lang.String,java.lang.String)>(v, v, "DRILL_MAX_DIRECT_MEMORY");
v = <org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String DRILLBIT_CODE_CACHE>;
virtualinvoke v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: void addIfSet(org.apache.drill.yarn.core.LaunchSpec,java.lang.String,java.lang.String)>(v, v, "DRILLBIT_CODE_CACHE_SIZE");
v = <org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String DRILLBIT_VM_ARGS>;
virtualinvoke v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: void addIfSet(org.apache.drill.yarn.core.LaunchSpec,java.lang.String,java.lang.String)>(v, v, "DRILL_JVM_OPTS");
v = <org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String JAVA_LIB_PATH>;
virtualinvoke v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: void addIfSet(org.apache.drill.yarn.core.LaunchSpec,java.lang.String,java.lang.String)>(v, v, "DOY_JAVA_LIB_PATH");
v = v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: com.typesafe.config.Config config>;
v = <org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String DISABLE_YARN_LOGS>;
v = interfaceinvoke v.<com.typesafe.config.Config: boolean getBoolean(java.lang.String)>(v);
if v != 0 goto label;
v = v.<org.apache.drill.yarn.core.LaunchSpec: java.util.Map env>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("DRILL_YARN_LOG_DIR", "<LOG_DIR>");
label:
v = v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: com.typesafe.config.Config config>;
v = <org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String DRILLBIT_DEBUG_LAUNCH>;
v = interfaceinvoke v.<com.typesafe.config.Config: boolean getBoolean(java.lang.String)>(v);
if v == 0 goto label;
v = v.<org.apache.drill.yarn.core.LaunchSpec: java.util.Map env>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("DRILL_DEBUG", "1");
label:
v = v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: com.typesafe.config.Config config>;
v = <org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String DRILLBIT_LOG_GC>;
v = interfaceinvoke v.<com.typesafe.config.Config: boolean getBoolean(java.lang.String)>(v);
if v == 0 goto label;
v = v.<org.apache.drill.yarn.core.LaunchSpec: java.util.Map env>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("ENABLE_GC_LOG", "1");
label:
v = <org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String DRILLBIT_PREFIX_CLASSPATH>;
virtualinvoke v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: void addIfSet(org.apache.drill.yarn.core.LaunchSpec,java.lang.String,java.lang.String)>(v, v, "DRILL_CLASSPATH_PREFIX");
v = <org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String DRILLBIT_CLASSPATH>;
virtualinvoke v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: void addIfSet(org.apache.drill.yarn.core.LaunchSpec,java.lang.String,java.lang.String)>(v, v, "DRILL_CLASSPATH");
v = <org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String DRILLBIT_EXTN_CLASSPATH>;
virtualinvoke v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: void addIfSet(org.apache.drill.yarn.core.LaunchSpec,java.lang.String,java.lang.String)>(v, v, "EXTN_CLASSPATH");
v = <org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String HADOOP_CLASSPATH>;
virtualinvoke v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: void addIfSet(org.apache.drill.yarn.core.LaunchSpec,java.lang.String,java.lang.String)>(v, v, "DRILL_HADOOP_CLASSPATH");
v = <org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String HBASE_CLASSPATH>;
virtualinvoke v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: void addIfSet(org.apache.drill.yarn.core.LaunchSpec,java.lang.String,java.lang.String)>(v, v, "DRILL_HBASE_CLASSPATH");
v.<org.apache.drill.yarn.core.LaunchSpec: java.lang.String command> = "$DRILL_HOME/bin/yarn-drillbit.sh";
v = virtualinvoke v.<org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String getRemoteSiteDir()>();
if v == null goto label;
v = v.<org.apache.drill.yarn.core.LaunchSpec: java.util.List cmdArgs>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>("--site");
v = v.<org.apache.drill.yarn.core.LaunchSpec: java.util.List cmdArgs>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
if v == null goto label;
v = v.<org.apache.drill.yarn.core.LaunchSpec: java.util.Map resources>;
interfaceinvoke v.<java.util.Map: void putAll(java.util.Map)>(v);
label:
v = new org.apache.drill.yarn.appMaster.TaskSpec;
specialinvoke v.<org.apache.drill.yarn.appMaster.TaskSpec: void <init>()>();
v.<org.apache.drill.yarn.appMaster.TaskSpec: java.lang.String name> = "Drillbit";
v.<org.apache.drill.yarn.appMaster.TaskSpec: org.apache.drill.yarn.core.ContainerRequestSpec containerSpec> = v;
v.<org.apache.drill.yarn.appMaster.TaskSpec: org.apache.drill.yarn.core.LaunchSpec launchSpec> = v;
v = v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: com.typesafe.config.Config config>;
v = <org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String DRILLBIT_MAX_RETRIES>;
v = interfaceinvoke v.<com.typesafe.config.Config: int getInt(java.lang.String)>(v);
v.<org.apache.drill.yarn.appMaster.TaskSpec: int maxRetries> = v;
return v;
}
public void addIfSet(org.apache.drill.yarn.core.LaunchSpec, java.lang.String, java.lang.String)
{
com.typesafe.config.Config v;
org.apache.drill.yarn.appMaster.DrillControllerFactory v;
org.apache.drill.yarn.core.LaunchSpec v;
java.util.Map v;
java.lang.String v, v, v;
boolean v;
v := @this: org.apache.drill.yarn.appMaster.DrillControllerFactory;
v := @parameter: org.apache.drill.yarn.core.LaunchSpec;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = v.<org.apache.drill.yarn.appMaster.DrillControllerFactory: com.typesafe.config.Config config>;
v = interfaceinvoke v.<com.typesafe.config.Config: java.lang.String getString(java.lang.String)>(v);
v = staticinvoke <org.apache.drill.yarn.core.DoYUtil: boolean isBlank(java.lang.String)>(v);
if v != 0 goto label;
v = v.<org.apache.drill.yarn.core.LaunchSpec: java.util.Map env>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
return;
}
private void buildZooKeeper(com.typesafe.config.Config, org.apache.drill.yarn.appMaster.Dispatcher)
{
org.apache.drill.yarn.zk.ZKRegistry v;
org.apache.drill.yarn.appMaster.DrillControllerFactory$ZKRegistryAddOn v;
org.apache.drill.yarn.appMaster.DrillControllerFactory v;
org.apache.drill.yarn.appMaster.Dispatcher v;
org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver v, v, v, v, v, v;
int v, v, v, v, v, v;
java.lang.String v, v, v;
org.apache.drill.yarn.appMaster.ClusterController v, v;
com.typesafe.config.Config v;
v := @this: org.apache.drill.yarn.appMaster.DrillControllerFactory;
v := @parameter: com.typesafe.config.Config;
v := @parameter: org.apache.drill.yarn.appMaster.Dispatcher;
v = interfaceinvoke v.<com.typesafe.config.Config: java.lang.String getString(java.lang.String)>("drill.exec.zk.connect");
v = interfaceinvoke v.<com.typesafe.config.Config: java.lang.String getString(java.lang.String)>("drill.exec.zk.root");
v = interfaceinvoke v.<com.typesafe.config.Config: java.lang.String getString(java.lang.String)>("drill.exec.cluster-id");
v = interfaceinvoke v.<com.typesafe.config.Config: int getInt(java.lang.String)>("drill.exec.zk.timeout");
v = interfaceinvoke v.<com.typesafe.config.Config: int getInt(java.lang.String)>("drill.exec.zk.retry.count");
v = interfaceinvoke v.<com.typesafe.config.Config: int getInt(java.lang.String)>("drill.exec.zk.retry.delay");
v = interfaceinvoke v.<com.typesafe.config.Config: int getInt(java.lang.String)>("drill.exec.rpc.user.server.port");
v = interfaceinvoke v.<com.typesafe.config.Config: int getInt(java.lang.String)>("drill.exec.rpc.bit.server.port");
v = new org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver;
specialinvoke v.<org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver: void <init>()>();
v = virtualinvoke v.<org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver: org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver setConnect(java.lang.String,java.lang.String,java.lang.String)>(v, v, v);
v = virtualinvoke v.<org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver: org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver setFailureTimoutMs(int)>(v);
v = virtualinvoke v.<org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver: org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver setRetryCount(int)>(v);
v = virtualinvoke v.<org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver: org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver setRetryDelayMs(int)>(v);
v = v + 1;
v = virtualinvoke v.<org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver: org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver setPorts(int,int,int)>(v, v, v);
v = new org.apache.drill.yarn.zk.ZKRegistry;
specialinvoke v.<org.apache.drill.yarn.zk.ZKRegistry: void <init>(org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver)>(v);
v = new org.apache.drill.yarn.appMaster.DrillControllerFactory$ZKRegistryAddOn;
specialinvoke v.<org.apache.drill.yarn.appMaster.DrillControllerFactory$ZKRegistryAddOn: void <init>(org.apache.drill.yarn.zk.ZKRegistry)>(v);
virtualinvoke v.<org.apache.drill.yarn.appMaster.Dispatcher: void registerAddOn(org.apache.drill.yarn.appMaster.DispatcherAddOn)>(v);
v = virtualinvoke v.<org.apache.drill.yarn.appMaster.Dispatcher: org.apache.drill.yarn.appMaster.ClusterController getController()>();
interfaceinvoke v.<org.apache.drill.yarn.appMaster.ClusterController: void registerLifecycleListener(org.apache.drill.yarn.appMaster.TaskLifecycleListener)>(v);
virtualinvoke v.<org.apache.drill.yarn.appMaster.Dispatcher: void setAMRegistrar(org.apache.drill.yarn.appMaster.AMRegistrar)>(v);
v = virtualinvoke v.<org.apache.drill.yarn.appMaster.Dispatcher: org.apache.drill.yarn.appMaster.ClusterController getController()>();
interfaceinvoke v.<org.apache.drill.yarn.appMaster.ClusterController: void setProperty(java.lang.String,java.lang.Object)>("zk", v);
return;
}
static void <clinit>()
{
org.apache.commons.logging.Log v;
v = staticinvoke <org.apache.commons.logging.LogFactory: org.apache.commons.logging.Log getLog(java.lang.Class)>(class "Lorg/apache/drill/yarn/appMaster/DrillControllerFactory;");
<org.apache.drill.yarn.appMaster.DrillControllerFactory: org.apache.commons.logging.Log LOG> = v;
return;
}
}