public class org.apache.drill.yarn.client.KillCommand extends org.apache.drill.yarn.client.ClientCommand
{
public void <init>()
{
org.apache.drill.yarn.client.KillCommand v;
v := @this: org.apache.drill.yarn.client.KillCommand;
specialinvoke v.<org.apache.drill.yarn.client.ClientCommand: void <init>()>();
return;
}
public void run() throws org.apache.drill.yarn.client.ClientException
{
java.io.PrintStream v, v;
org.apache.drill.yarn.core.YarnRMClient v;
org.apache.drill.yarn.client.ClientException v, v;
org.apache.drill.yarn.core.YarnClientException v, v;
org.apache.hadoop.yarn.api.records.ApplicationId v;
int v;
java.lang.String v, v, v, v;
org.apache.drill.yarn.client.KillCommand v;
v := @this: org.apache.drill.yarn.client.KillCommand;
v = virtualinvoke v.<org.apache.drill.yarn.client.KillCommand: org.apache.hadoop.yarn.api.records.ApplicationId checkAppId()>();
if v != null goto label;
v = (int) -1;
staticinvoke <java.lang.System: void exit(int)>(v);
label:
v = new org.apache.drill.yarn.core.YarnRMClient;
specialinvoke v.<org.apache.drill.yarn.core.YarnRMClient: void <init>(org.apache.hadoop.yarn.api.records.ApplicationId)>(v);
label:
virtualinvoke v.<org.apache.drill.yarn.core.YarnRMClient: void killApplication()>();
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.Exception)>(v);
throw v;
label:
v = <java.lang.System: java.io.PrintStream out>;
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>("Kill request sent, waiting for shut-down.");
label:
virtualinvoke v.<org.apache.drill.yarn.core.YarnRMClient: void waitForCompletion()>();
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.drill.yarn.client.ClientException;
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[])>("Wait for completion failed for app id: \u0001");
specialinvoke v.<org.apache.drill.yarn.client.ClientException: void <init>(java.lang.String,java.lang.Exception)>(v, v);
throw v;
label:
v = <java.lang.System: java.io.PrintStream out>;
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 completed: \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;
catch org.apache.drill.yarn.core.YarnClientException from label to label with label;
}
}