public class org.apache.drill.yarn.client.AMRunner extends java.lang.Object
{
private com.typesafe.config.Config config;
private boolean verbose;
private org.apache.hadoop.yarn.api.records.ApplicationId appId;
public java.util.Map resources;
public java.lang.String drillArchivePath;
public java.lang.String siteArchivePath;
public java.lang.String remoteDrillHome;
public java.lang.String remoteSiteDir;
private org.apache.drill.yarn.core.YarnRMClient client;
private org.apache.hadoop.yarn.api.protocolrecords.GetNewApplicationResponse appResponse;
private boolean dryRun;
public void <init>(com.typesafe.config.Config, boolean, boolean)
{
com.typesafe.config.Config v;
org.apache.drill.yarn.client.AMRunner v;
boolean v, v;
v := @this: org.apache.drill.yarn.client.AMRunner;
v := @parameter: com.typesafe.config.Config;
v := @parameter: boolean;
v := @parameter: boolean;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.drill.yarn.client.AMRunner: com.typesafe.config.Config config> = v;
v.<org.apache.drill.yarn.client.AMRunner: boolean verbose> = v;
v.<org.apache.drill.yarn.client.AMRunner: boolean dryRun> = v;
return;
}
public void run() throws org.apache.drill.yarn.client.ClientException
{
org.apache.drill.yarn.client.AMRunner v;
boolean v;
v := @this: org.apache.drill.yarn.client.AMRunner;
specialinvoke v.<org.apache.drill.yarn.client.AMRunner: void connectToYarn()>();
v = v.<org.apache.drill.yarn.client.AMRunner: boolean dryRun>;
if v == 0 goto label;
specialinvoke v.<org.apache.drill.yarn.client.AMRunner: void doDryRun()>();
goto label;
label:
specialinvoke v.<org.apache.drill.yarn.client.AMRunner: void doLaunch()>();
label:
return;
}
private void connectToYarn()
{
java.io.PrintStream v, v;
org.apache.drill.yarn.core.YarnRMClient v;
org.apache.drill.yarn.client.AMRunner v;
v := @this: org.apache.drill.yarn.client.AMRunner;
v = <java.lang.System: java.io.PrintStream out>;
virtualinvoke v.<java.io.PrintStream: void print(java.lang.String)>("Loading YARN Config...");
v = new org.apache.drill.yarn.core.YarnRMClient;
specialinvoke v.<org.apache.drill.yarn.core.YarnRMClient: void <init>()>();
v.<org.apache.drill.yarn.client.AMRunner: org.apache.drill.yarn.core.YarnRMClient client> = v;
v = <java.lang.System: java.io.PrintStream out>;
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(" Loaded.");
return;
}
private void doDryRun() throws org.apache.drill.yarn.client.ClientException
{
java.io.PrintStream v;
org.apache.drill.yarn.client.AMRunner v;
org.apache.drill.yarn.core.AppSpec v;
v := @this: org.apache.drill.yarn.client.AMRunner;
v = specialinvoke v.<org.apache.drill.yarn.client.AMRunner: org.apache.drill.yarn.core.AppSpec buildSpec()>();
v = <java.lang.System: java.io.PrintStream out>;
specialinvoke v.<org.apache.drill.yarn.client.AMRunner: void dump(org.apache.drill.yarn.core.AppSpec,java.io.PrintStream)>(v, v);
return;
}
private void doLaunch() throws org.apache.drill.yarn.client.ClientException
{
java.io.PrintStream v;
java.lang.String v;
org.apache.drill.yarn.client.AMRunner v;
org.apache.drill.yarn.core.AppSpec v;
boolean v;
v := @this: org.apache.drill.yarn.client.AMRunner;
specialinvoke v.<org.apache.drill.yarn.client.AMRunner: void createApp()>();
v = specialinvoke v.<org.apache.drill.yarn.client.AMRunner: org.apache.drill.yarn.core.AppSpec buildSpec()>();
v = v.<org.apache.drill.yarn.client.AMRunner: boolean verbose>;
if v == 0 goto label;
v = <java.lang.System: java.io.PrintStream out>;
specialinvoke v.<org.apache.drill.yarn.client.AMRunner: void dump(org.apache.drill.yarn.core.AppSpec,java.io.PrintStream)>(v, v);
label:
specialinvoke v.<org.apache.drill.yarn.client.AMRunner: void validateResources(org.apache.drill.yarn.core.AppSpec)>(v);
specialinvoke v.<org.apache.drill.yarn.client.AMRunner: void launchApp(org.apache.drill.yarn.core.AppSpec)>(v);
v = v.<org.apache.drill.yarn.core.AppSpec: java.lang.String appName>;
specialinvoke v.<org.apache.drill.yarn.client.AMRunner: void waitForStartAndReport(java.lang.String)>(v);
specialinvoke v.<org.apache.drill.yarn.client.AMRunner: void writeAppIdFile()>();
return;
}
private void dump(org.apache.drill.yarn.core.AppSpec, java.io.PrintStream)
{
java.io.PrintStream v;
org.apache.drill.yarn.client.AMRunner v;
org.apache.drill.yarn.core.AppSpec v;
v := @this: org.apache.drill.yarn.client.AMRunner;
v := @parameter: org.apache.drill.yarn.core.AppSpec;
v := @parameter: java.io.PrintStream;
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>("----------------------------------------------");
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>("Application Master Launch Spec");
virtualinvoke v.<org.apache.drill.yarn.core.AppSpec: void dump(java.io.PrintStream)>(v);
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>("----------------------------------------------");
return;
}
private org.apache.drill.yarn.core.AppSpec buildSpec() throws org.apache.drill.yarn.client.ClientException
{
org.apache.drill.yarn.client.AMRunner v;
java.util.Map v, v, v, v, v, v, v, v;
boolean v, v, v, v;
java.util.List v, v;
org.apache.hadoop.yarn.api.records.ApplicationId 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, v, v, v, v, v, v, v;
double v;
com.typesafe.config.Config v, v, v, v, v, v, v, v, v, v, v;
org.apache.drill.yarn.core.AppSpec v;
v := @this: org.apache.drill.yarn.client.AMRunner;
v = new org.apache.drill.yarn.core.AppSpec;
specialinvoke v.<org.apache.drill.yarn.core.AppSpec: void <init>()>();
v = v.<org.apache.drill.yarn.client.AMRunner: com.typesafe.config.Config config>;
v = <org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String AM_HEAP>;
v = interfaceinvoke v.<com.typesafe.config.Config: java.lang.String getString(java.lang.String)>(v);
v = v.<org.apache.drill.yarn.core.AppSpec: java.util.Map env>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("DRILL_AM_HEAP", v);
v = <org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String AM_VM_ARGS>;
specialinvoke v.<org.apache.drill.yarn.client.AMRunner: void addIfSet(org.apache.drill.yarn.core.LaunchSpec,java.lang.String,java.lang.String)>(v, v, "DRILL_AM_JAVA_OPTS");
v = <org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String AM_PREFIX_CLASSPATH>;
specialinvoke v.<org.apache.drill.yarn.client.AMRunner: 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 AM_CLASSPATH>;
specialinvoke v.<org.apache.drill.yarn.client.AMRunner: 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 JAVA_LIB_PATH>;
specialinvoke v.<org.apache.drill.yarn.client.AMRunner: 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.client.AMRunner: 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.AppSpec: 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.client.AMRunner: java.lang.String remoteDrillHome>;
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/bin/drill-am.sh");
v.<org.apache.drill.yarn.core.AppSpec: java.lang.String command> = v;
v = v.<org.apache.drill.yarn.client.AMRunner: java.lang.String remoteSiteDir>;
if v == null goto label;
v = v.<org.apache.drill.yarn.core.AppSpec: java.util.List cmdArgs>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>("--site");
v = v.<org.apache.drill.yarn.core.AppSpec: java.util.List cmdArgs>;
v = v.<org.apache.drill.yarn.client.AMRunner: java.lang.String remoteSiteDir>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
v = v.<org.apache.drill.yarn.client.AMRunner: boolean dryRun>;
if v == 0 goto label;
v = "Unknown";
goto label;
label:
v = v.<org.apache.drill.yarn.client.AMRunner: org.apache.hadoop.yarn.api.records.ApplicationId appId>;
v = virtualinvoke v.<org.apache.hadoop.yarn.api.records.ApplicationId: java.lang.String toString()>();
label:
v = v.<org.apache.drill.yarn.core.AppSpec: java.util.Map env>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("DRILL_AM_APP_ID", v);
v = v.<org.apache.drill.yarn.client.AMRunner: com.typesafe.config.Config config>;
v = <org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String AM_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.AppSpec: 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.client.AMRunner: com.typesafe.config.Config config>;
v = <org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String LOCALIZE_DRILL>;
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.AppSpec: java.util.Map env>;
v = v.<org.apache.drill.yarn.client.AMRunner: java.lang.String drillArchivePath>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("DRILL_ARCHIVE", v);
v = v.<org.apache.drill.yarn.client.AMRunner: java.lang.String siteArchivePath>;
if v == null goto label;
v = v.<org.apache.drill.yarn.core.AppSpec: java.util.Map env>;
v = v.<org.apache.drill.yarn.client.AMRunner: java.lang.String siteArchivePath>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("SITE_ARCHIVE", v);
label:
v = v.<org.apache.drill.yarn.core.AppSpec: java.util.Map resources>;
v = v.<org.apache.drill.yarn.client.AMRunner: java.util.Map resources>;
interfaceinvoke v.<java.util.Map: void putAll(java.util.Map)>(v);
v = v.<org.apache.drill.yarn.client.AMRunner: com.typesafe.config.Config config>;
v = <org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String AM_MEMORY>;
v = interfaceinvoke v.<com.typesafe.config.Config: int getInt(java.lang.String)>(v);
v.<org.apache.drill.yarn.core.AppSpec: int memoryMb> = v;
v = v.<org.apache.drill.yarn.client.AMRunner: com.typesafe.config.Config config>;
v = <org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String AM_VCORES>;
v = interfaceinvoke v.<com.typesafe.config.Config: int getInt(java.lang.String)>(v);
v.<org.apache.drill.yarn.core.AppSpec: int vCores> = v;
v = v.<org.apache.drill.yarn.client.AMRunner: com.typesafe.config.Config config>;
v = <org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String AM_DISKS>;
v = interfaceinvoke v.<com.typesafe.config.Config: double getDouble(java.lang.String)>(v);
v.<org.apache.drill.yarn.core.AppSpec: double disks> = v;
v = v.<org.apache.drill.yarn.client.AMRunner: 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.<org.apache.drill.yarn.core.AppSpec: java.lang.String appName> = v;
v = v.<org.apache.drill.yarn.client.AMRunner: com.typesafe.config.Config config>;
v = <org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String YARN_QUEUE>;
v = interfaceinvoke v.<com.typesafe.config.Config: java.lang.String getString(java.lang.String)>(v);
v.<org.apache.drill.yarn.core.AppSpec: java.lang.String queueName> = v;
v = v.<org.apache.drill.yarn.client.AMRunner: com.typesafe.config.Config config>;
v = <org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String YARN_PRIORITY>;
v = interfaceinvoke v.<com.typesafe.config.Config: int getInt(java.lang.String)>(v);
v.<org.apache.drill.yarn.core.AppSpec: int priority> = v;
v = v.<org.apache.drill.yarn.client.AMRunner: com.typesafe.config.Config config>;
v = <org.apache.drill.yarn.core.DrillOnYarnConfig: java.lang.String AM_NODE_LABEL_EXPR>;
v = interfaceinvoke v.<com.typesafe.config.Config: java.lang.String getString(java.lang.String)>(v);
v.<org.apache.drill.yarn.core.AppSpec: java.lang.String nodeLabelExpr> = v;
return v;
}
private void addIfSet(org.apache.drill.yarn.core.LaunchSpec, java.lang.String, java.lang.String)
{
com.typesafe.config.Config v;
org.apache.drill.yarn.client.AMRunner 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.client.AMRunner;
v := @parameter: org.apache.drill.yarn.core.LaunchSpec;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = v.<org.apache.drill.yarn.client.AMRunner: 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 createApp() throws org.apache.drill.yarn.client.ClientException
{
java.io.PrintStream v;
org.apache.drill.yarn.core.YarnRMClient v;
org.apache.hadoop.yarn.api.protocolrecords.GetNewApplicationResponse v, v;
org.apache.drill.yarn.client.AMRunner v;
org.apache.drill.yarn.client.ClientException v;
org.apache.drill.yarn.core.YarnClientException v;
org.apache.hadoop.yarn.api.records.ApplicationId v, v;
java.lang.String v, v;
v := @this: org.apache.drill.yarn.client.AMRunner;
label:
v = v.<org.apache.drill.yarn.client.AMRunner: org.apache.drill.yarn.core.YarnRMClient client>;
v = virtualinvoke v.<org.apache.drill.yarn.core.YarnRMClient: org.apache.hadoop.yarn.api.protocolrecords.GetNewApplicationResponse createAppMaster()>();
v.<org.apache.drill.yarn.client.AMRunner: org.apache.hadoop.yarn.api.protocolrecords.GetNewApplicationResponse appResponse> = v;
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.drill.yarn.client.ClientException;
specialinvoke v.<org.apache.drill.yarn.client.ClientException: void <init>(java.lang.String,java.lang.Exception)>("Failed to allocate Drill application master", v);
throw v;
label:
v = v.<org.apache.drill.yarn.client.AMRunner: org.apache.hadoop.yarn.api.protocolrecords.GetNewApplicationResponse appResponse>;
v = virtualinvoke v.<org.apache.hadoop.yarn.api.protocolrecords.GetNewApplicationResponse: org.apache.hadoop.yarn.api.records.ApplicationId getApplicationId()>();
v.<org.apache.drill.yarn.client.AMRunner: org.apache.hadoop.yarn.api.records.ApplicationId appId> = v;
v = <java.lang.System: java.io.PrintStream out>;
v = v.<org.apache.drill.yarn.client.AMRunner: org.apache.hadoop.yarn.api.records.ApplicationId appId>;
v = virtualinvoke v.<org.apache.hadoop.yarn.api.records.ApplicationId: 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[])>("Application ID: \u0001");
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
return;
catch org.apache.drill.yarn.core.YarnClientException from label to label with label;
}
private void validateResources(org.apache.drill.yarn.core.AppSpec) throws org.apache.drill.yarn.client.ClientException
{
org.apache.drill.yarn.client.AMRunner v;
org.apache.hadoop.yarn.api.records.Resource v, v;
boolean v;
int v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v;
java.io.PrintStream v, v;
com.typesafe.config.Config v, v, v, v;
org.apache.hadoop.yarn.api.protocolrecords.GetNewApplicationResponse v, v;
org.apache.drill.yarn.client.ClientException v, v, v, v;
org.apache.drill.yarn.core.AppSpec v;
v := @this: org.apache.drill.yarn.client.AMRunner;
v := @parameter: org.apache.drill.yarn.core.AppSpec;
v = v.<org.apache.drill.yarn.client.AMRunner: org.apache.hadoop.yarn.api.protocolrecords.GetNewApplicationResponse appResponse>;
v = virtualinvoke v.<org.apache.hadoop.yarn.api.protocolrecords.GetNewApplicationResponse: org.apache.hadoop.yarn.api.records.Resource getMaximumResourceCapability()>();
v = virtualinvoke v.<org.apache.hadoop.yarn.api.records.Resource: int getMemory()>();
v = v.<org.apache.drill.yarn.client.AMRunner: org.apache.hadoop.yarn.api.protocolrecords.GetNewApplicationResponse appResponse>;
v = virtualinvoke v.<org.apache.hadoop.yarn.api.protocolrecords.GetNewApplicationResponse: org.apache.hadoop.yarn.api.records.Resource getMaximumResourceCapability()>();
v = virtualinvoke v.<org.apache.hadoop.yarn.api.records.Resource: int getVirtualCores()>();
v = v.<org.apache.drill.yarn.client.AMRunner: boolean verbose>;
if v == 0 goto label;
v = <java.lang.System: java.io.PrintStream out>;
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[])>("Max Memory: \u0001");
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
v = <java.lang.System: java.io.PrintStream out>;
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[])>("Max Cores: \u0001");
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
label:
v = v.<org.apache.drill.yarn.core.AppSpec: int memoryMb>;
if v <= v goto label;
v = new org.apache.drill.yarn.client.ClientException;
v = v.<org.apache.drill.yarn.core.AppSpec: int memoryMb>;
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 maximum memory is \u but the application master requests \u0001");
specialinvoke v.<org.apache.drill.yarn.client.ClientException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<org.apache.drill.yarn.core.AppSpec: int vCores>;
if v <= v goto label;
v = new org.apache.drill.yarn.client.ClientException;
v = v.<org.apache.drill.yarn.core.AppSpec: int vCores>;
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 maximum vcores is \u but the application master requests \u0001");
specialinvoke v.<org.apache.drill.yarn.client.ClientException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<org.apache.drill.yarn.client.AMRunner: 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);
if v <= v goto label;
v = new org.apache.drill.yarn.client.ClientException;
v = v.<org.apache.drill.yarn.client.AMRunner: 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 = 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 maximum memory is \u but the Drillbit requests \u0001");
specialinvoke v.<org.apache.drill.yarn.client.ClientException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<org.apache.drill.yarn.client.AMRunner: 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);
if v <= v goto label;
v = new org.apache.drill.yarn.client.ClientException;
v = v.<org.apache.drill.yarn.client.AMRunner: 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 = 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 maximum vcores is \u but the Drillbit requests \u0001");
specialinvoke v.<org.apache.drill.yarn.client.ClientException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
}
private void launchApp(org.apache.drill.yarn.core.AppSpec) throws org.apache.drill.yarn.client.ClientException
{
org.apache.drill.yarn.client.ClientException v;
org.apache.drill.yarn.core.YarnClientException v;
org.apache.drill.yarn.core.YarnRMClient v;
org.apache.drill.yarn.client.AMRunner v;
org.apache.drill.yarn.core.AppSpec v;
v := @this: org.apache.drill.yarn.client.AMRunner;
v := @parameter: org.apache.drill.yarn.core.AppSpec;
label:
v = v.<org.apache.drill.yarn.client.AMRunner: org.apache.drill.yarn.core.YarnRMClient client>;
virtualinvoke v.<org.apache.drill.yarn.core.YarnRMClient: void submitAppMaster(org.apache.drill.yarn.core.AppSpec)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.drill.yarn.client.ClientException;
specialinvoke v.<org.apache.drill.yarn.client.ClientException: void <init>(java.lang.String,java.lang.Exception)>("Failed to start Drill application master", v);
throw v;
label:
return;
catch org.apache.drill.yarn.core.YarnClientException from label to label with label;
}
private void writeAppIdFile() throws org.apache.drill.yarn.client.ClientException
{
java.io.PrintWriter v;
java.io.FileWriter v;
java.io.IOException v;
org.apache.drill.yarn.client.AMRunner v;
java.io.File v;
org.apache.drill.yarn.client.ClientException v;
org.apache.hadoop.yarn.api.records.ApplicationId v;
java.lang.String v, v;
v := @this: org.apache.drill.yarn.client.AMRunner;
v = staticinvoke <org.apache.drill.yarn.client.ClientCommand: java.io.File getAppIdFile()>();
label:
v = new java.io.PrintWriter;
v = new java.io.FileWriter;
specialinvoke v.<java.io.FileWriter: void <init>(java.io.File)>(v);
specialinvoke v.<java.io.PrintWriter: void <init>(java.io.Writer)>(v);
v = v.<org.apache.drill.yarn.client.AMRunner: org.apache.hadoop.yarn.api.records.ApplicationId appId>;
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.Object)>(v);
virtualinvoke v.<java.io.PrintWriter: void close()>();
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.drill.yarn.client.ClientException;
v = virtualinvoke v.<java.io.File: java.lang.String getAbsolutePath()>();
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[])>("Failed to write appid file: \u0001");
specialinvoke v.<org.apache.drill.yarn.client.ClientException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
catch java.io.IOException from label to label with label;
}
private void waitForStartAndReport(java.lang.String) throws org.apache.drill.yarn.client.ClientException
{
java.lang.String v;
org.apache.drill.yarn.client.AMRunner v;
org.apache.drill.yarn.client.AMRunner$StartMonitor v;
v := @this: org.apache.drill.yarn.client.AMRunner;
v := @parameter: java.lang.String;
v = new org.apache.drill.yarn.client.AMRunner$StartMonitor;
specialinvoke v.<org.apache.drill.yarn.client.AMRunner$StartMonitor: void <init>(org.apache.drill.yarn.client.AMRunner)>(v);
virtualinvoke v.<org.apache.drill.yarn.client.AMRunner$StartMonitor: void run(java.lang.String)>(v);
return;
}
}