public class org.apache.hive.hcatalog.templeton.JobRequestExecutor extends java.lang.Object
{
private static final org.slf4j.Logger LOG;
private static org.apache.hive.hcatalog.templeton.AppConfig appConf;
private java.util.concurrent.ThreadPoolExecutor jobExecutePool;
private org.apache.hive.hcatalog.templeton.JobRequestExecutor$JobRequestType requestType;
private java.lang.String concurrentRequestsConfigName;
private java.lang.String jobTimeoutConfigName;
private int requestExecutionTimeoutInSec;
private int threadKeepAliveTimeInHours;
private int maxTaskCancelRetryCount;
private int maxTaskCancelRetryWaitTimeInMs;
private boolean enableCancelTask;
static final boolean $assertionsDisabled;
public void <init>(org.apache.hive.hcatalog.templeton.JobRequestExecutor$JobRequestType, java.lang.String, java.lang.String, boolean)
{
java.util.concurrent.ThreadPoolExecutor v, v;
org.apache.hive.hcatalog.templeton.JobRequestExecutor$JobRequestType v, v, v;
int v, v, v, v, v;
java.lang.String v, v, v, v;
boolean v, v, v;
org.slf4j.Logger v, v;
java.util.concurrent.SynchronousQueue v;
java.util.concurrent.TimeUnit v;
org.apache.hive.hcatalog.templeton.JobRequestExecutor v;
org.apache.hive.hcatalog.templeton.AppConfig v, v;
v := @this: org.apache.hive.hcatalog.templeton.JobRequestExecutor;
v := @parameter: org.apache.hive.hcatalog.templeton.JobRequestExecutor$JobRequestType;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: boolean;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: java.util.concurrent.ThreadPoolExecutor jobExecutePool> = null;
v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: int requestExecutionTimeoutInSec> = 0;
v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: int threadKeepAliveTimeInHours> = 1;
v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: int maxTaskCancelRetryCount> = 10;
v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: int maxTaskCancelRetryWaitTimeInMs> = 1000;
v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: boolean enableCancelTask> = 1;
v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: java.lang.String concurrentRequestsConfigName> = v;
v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: java.lang.String jobTimeoutConfigName> = v;
v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: org.apache.hive.hcatalog.templeton.JobRequestExecutor$JobRequestType requestType> = v;
v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: boolean enableCancelTask> = v;
v = staticinvoke <org.apache.commons.lang.StringUtils: boolean isEmpty(java.lang.CharSequence)>(v);
if v != 0 goto label;
v = <org.apache.hive.hcatalog.templeton.JobRequestExecutor: org.apache.hive.hcatalog.templeton.AppConfig appConf>;
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.AppConfig: int getInt(java.lang.String,int)>(v, 0);
goto label;
label:
v = 0;
label:
v = v;
if v <= 0 goto label;
v = new java.util.concurrent.ThreadPoolExecutor;
v = v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: int threadKeepAliveTimeInHours>;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit HOURS>;
v = new java.util.concurrent.SynchronousQueue;
specialinvoke v.<java.util.concurrent.SynchronousQueue: void <init>()>();
specialinvoke v.<java.util.concurrent.ThreadPoolExecutor: void <init>(int,int,long,java.util.concurrent.TimeUnit,java.util.concurrent.BlockingQueue)>(v, v, v, v, v);
v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: java.util.concurrent.ThreadPoolExecutor jobExecutePool> = v;
v = v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: java.util.concurrent.ThreadPoolExecutor jobExecutePool>;
virtualinvoke v.<java.util.concurrent.ThreadPoolExecutor: void allowCoreThreadTimeOut(boolean)>(1);
v = staticinvoke <org.apache.commons.lang.StringUtils: boolean isEmpty(java.lang.CharSequence)>(v);
if v != 0 goto label;
v = <org.apache.hive.hcatalog.templeton.JobRequestExecutor: org.apache.hive.hcatalog.templeton.AppConfig appConf>;
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.AppConfig: int getInt(java.lang.String,int)>(v, 0);
v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: int requestExecutionTimeoutInSec> = v;
label:
v = <org.apache.hive.hcatalog.templeton.JobRequestExecutor: org.slf4j.Logger LOG>;
v = v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: org.apache.hive.hcatalog.templeton.JobRequestExecutor$JobRequestType requestType>;
v = v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: int requestExecutionTimeoutInSec>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int,org.apache.hive.hcatalog.templeton.JobRequestExecutor$JobRequestType,int)>(v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Configured \u threads for job request type \u with time out \u s.");
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
goto label;
label:
v = <org.apache.hive.hcatalog.templeton.JobRequestExecutor: org.slf4j.Logger LOG>;
v = v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: org.apache.hive.hcatalog.templeton.JobRequestExecutor$JobRequestType requestType>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.hive.hcatalog.templeton.JobRequestExecutor$JobRequestType)>(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[])>("No thread pool configured for job request type \u0001");
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
label:
return;
}
public void <init>(org.apache.hive.hcatalog.templeton.JobRequestExecutor$JobRequestType, java.lang.String, java.lang.String)
{
org.apache.hive.hcatalog.templeton.JobRequestExecutor v;
org.apache.hive.hcatalog.templeton.JobRequestExecutor$JobRequestType v;
java.lang.String v, v;
v := @this: org.apache.hive.hcatalog.templeton.JobRequestExecutor;
v := @parameter: org.apache.hive.hcatalog.templeton.JobRequestExecutor$JobRequestType;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
specialinvoke v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: void <init>(org.apache.hive.hcatalog.templeton.JobRequestExecutor$JobRequestType,java.lang.String,java.lang.String,boolean)>(v, v, v, 1);
return;
}
public boolean isThreadPoolEnabled()
{
org.apache.hive.hcatalog.templeton.JobRequestExecutor v;
java.util.concurrent.ThreadPoolExecutor v;
boolean v;
v := @this: org.apache.hive.hcatalog.templeton.JobRequestExecutor;
v = v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: java.util.concurrent.ThreadPoolExecutor jobExecutePool>;
if v == null goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public java.lang.Object execute(org.apache.hive.hcatalog.templeton.JobCallable) throws java.lang.InterruptedException, java.util.concurrent.TimeoutException, org.apache.hive.hcatalog.templeton.TooManyRequestsException, java.util.concurrent.ExecutionException
{
org.apache.hive.hcatalog.templeton.JobRequestExecutor$JobRequestType v, v, v, v;
java.util.concurrent.TimeoutException v, v;
org.apache.hive.hcatalog.templeton.TooManyRequestsException v;
java.util.concurrent.Future v;
boolean v, v, v, v, v, v, v;
java.util.concurrent.CancellationException v;
org.apache.hive.hcatalog.templeton.JobRequestExecutor v;
java.lang.Throwable v;
org.apache.hive.hcatalog.templeton.JobCallable v;
java.util.concurrent.ThreadPoolExecutor v, v;
java.lang.AssertionError v, v;
java.util.concurrent.RejectedExecutionException v;
int v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v;
org.slf4j.Logger v, v, v, v, v, v;
java.util.concurrent.TimeUnit v;
java.lang.InterruptedException v, v, v;
java.lang.Object v, v, v, v, v;
v := @this: org.apache.hive.hcatalog.templeton.JobRequestExecutor;
v := @parameter: org.apache.hive.hcatalog.templeton.JobCallable;
v = <org.apache.hive.hcatalog.templeton.JobRequestExecutor: boolean $assertionsDisabled>;
if v != 0 goto label;
if v != null goto label;
v = new java.lang.AssertionError;
specialinvoke v.<java.lang.AssertionError: void <init>()>();
throw v;
label:
v = <org.apache.hive.hcatalog.templeton.JobRequestExecutor: boolean $assertionsDisabled>;
if v != 0 goto label;
v = v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: java.util.concurrent.ThreadPoolExecutor jobExecutePool>;
if v != null goto label;
v = new java.lang.AssertionError;
specialinvoke v.<java.lang.AssertionError: void <init>()>();
throw v;
label:
v = v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: org.apache.hive.hcatalog.templeton.JobRequestExecutor$JobRequestType requestType>;
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor$JobRequestType: java.lang.String toString()>();
v = virtualinvoke v.<java.lang.String: java.lang.String toLowerCase()>();
v = v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: java.lang.String concurrentRequestsConfigName>;
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[])>("Please wait for some time before retrying the operation. Please refer to the config \u to configure concurrent requests.");
v = <org.apache.hive.hcatalog.templeton.JobRequestExecutor: org.slf4j.Logger LOG>;
v = v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: int requestExecutionTimeoutInSec>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,int)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Starting new \u job request with time out \u0001seconds.");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
label:
v = v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: java.util.concurrent.ThreadPoolExecutor jobExecutePool>;
v = virtualinvoke v.<java.util.concurrent.ThreadPoolExecutor: java.util.concurrent.Future submit(java.util.concurrent.Callable)>(v);
label:
goto label;
label:
v := @caughtexception;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,java.lang.String)>(v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Unable to service the \u job request as templeton service is busy with too many \u job requests. \u0001");
v = <org.apache.hive.hcatalog.templeton.JobRequestExecutor: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>(v);
v = new org.apache.hive.hcatalog.templeton.TooManyRequestsException;
specialinvoke v.<org.apache.hive.hcatalog.templeton.TooManyRequestsException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: int requestExecutionTimeoutInSec>;
if v <= 0 goto label;
v = v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: int requestExecutionTimeoutInSec>;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit SECONDS>;
v = interfaceinvoke v.<java.util.concurrent.Future: java.lang.Object get(long,java.util.concurrent.TimeUnit)>(v, v);
goto label;
label:
v = interfaceinvoke v.<java.util.concurrent.Future: java.lang.Object get()>();
label:
v = v;
label:
v = v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: boolean enableCancelTask>;
if v == 0 goto label;
specialinvoke v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: void cancelExecutePoolThread(java.util.concurrent.Future)>(v);
goto label;
label:
v := @caughtexception;
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: java.lang.Object tryGetJobResultOrSetJobStateFailed(org.apache.hive.hcatalog.templeton.JobCallable)>(v);
v = v;
if v != null goto label;
v = v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: org.apache.hive.hcatalog.templeton.JobRequestExecutor$JobRequestType requestType>;
v = v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: java.lang.String jobTimeoutConfigName>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.hive.hcatalog.templeton.JobRequestExecutor$JobRequestType,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[])>("\u job request got timed out. Please wait for some time before retrying the operation. Please refer to the config \u to configure job request time out.");
v = <org.apache.hive.hcatalog.templeton.JobRequestExecutor: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>(v);
v = new java.util.concurrent.TimeoutException;
specialinvoke v.<java.util.concurrent.TimeoutException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: boolean enableCancelTask>;
if v == 0 goto label;
specialinvoke v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: void cancelExecutePoolThread(java.util.concurrent.Future)>(v);
goto label;
label:
v := @caughtexception;
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: java.lang.Object tryGetJobResultOrSetJobStateFailed(org.apache.hive.hcatalog.templeton.JobCallable)>(v);
v = v;
if v != null goto label;
v = v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: org.apache.hive.hcatalog.templeton.JobRequestExecutor$JobRequestType requestType>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.hive.hcatalog.templeton.JobRequestExecutor$JobRequestType)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u job request got interrupted. Please wait for some time before retrying the operation.");
v = <org.apache.hive.hcatalog.templeton.JobRequestExecutor: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>(v);
v = new java.lang.InterruptedException;
specialinvoke v.<java.lang.InterruptedException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: boolean enableCancelTask>;
if v == 0 goto label;
specialinvoke v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: void cancelExecutePoolThread(java.util.concurrent.Future)>(v);
goto label;
label:
v := @caughtexception;
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: java.lang.Object tryGetJobResultOrSetJobStateFailed(org.apache.hive.hcatalog.templeton.JobCallable)>(v);
v = v;
if v != null goto label;
v = v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: org.apache.hive.hcatalog.templeton.JobRequestExecutor$JobRequestType requestType>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.hive.hcatalog.templeton.JobRequestExecutor$JobRequestType)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u job request got cancelled and thread got interrupted. Please wait for some time before retrying the operation.");
v = <org.apache.hive.hcatalog.templeton.JobRequestExecutor: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>(v);
v = new java.lang.InterruptedException;
specialinvoke v.<java.lang.InterruptedException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: boolean enableCancelTask>;
if v == 0 goto label;
specialinvoke v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: void cancelExecutePoolThread(java.util.concurrent.Future)>(v);
goto label;
label:
v := @caughtexception;
v = v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: boolean enableCancelTask>;
if v == 0 goto label;
specialinvoke v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: void cancelExecutePoolThread(java.util.concurrent.Future)>(v);
label:
throw v;
label:
v = <org.apache.hive.hcatalog.templeton.JobRequestExecutor: org.slf4j.Logger 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[])>("Completed \u job request.");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
return v;
catch java.util.concurrent.RejectedExecutionException from label to label with label;
catch java.util.concurrent.TimeoutException from label to label with label;
catch java.lang.InterruptedException from label to label with label;
catch java.util.concurrent.CancellationException from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
private void cancelExecutePoolThread(java.util.concurrent.Future)
{
org.slf4j.Logger v, v, v;
java.util.concurrent.Future v;
org.apache.hive.hcatalog.templeton.JobRequestExecutor v;
java.lang.InterruptedException v;
int v, v, v;
java.lang.String v, v;
boolean v, v, v;
v := @this: org.apache.hive.hcatalog.templeton.JobRequestExecutor;
v := @parameter: java.util.concurrent.Future;
v = 0;
label:
v = v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: int maxTaskCancelRetryCount>;
if v >= v goto label;
v = interfaceinvoke v.<java.util.concurrent.Future: boolean isDone()>();
if v != 0 goto label;
v = <org.apache.hive.hcatalog.templeton.JobRequestExecutor: org.slf4j.Logger 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[])>("Task is still executing the job request. Cancelling it with retry count: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
v = interfaceinvoke v.<java.util.concurrent.Future: boolean cancel(boolean)>(1);
if v == 0 goto label;
v = <org.apache.hive.hcatalog.templeton.JobRequestExecutor: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Cancel job request issued successfully.");
return;
label:
v = v + 1;
label:
v = v.<org.apache.hive.hcatalog.templeton.JobRequestExecutor: int maxTaskCancelRetryWaitTimeInMs>;
staticinvoke <java.lang.Thread: void sleep(long)>(v);
label:
goto label;
label:
v := @caughtexception;
goto label;
label:
v = <org.apache.hive.hcatalog.templeton.JobRequestExecutor: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<java.util.concurrent.Future: boolean isCancelled()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (boolean,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[])>("Failed to cancel the job. isCancelled: \u Retry count: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>(v);
return;
catch java.lang.InterruptedException from label to label with label;
}
private java.lang.Object tryGetJobResultOrSetJobStateFailed(org.apache.hive.hcatalog.templeton.JobCallable)
{
org.slf4j.Logger v, v;
org.apache.hive.hcatalog.templeton.JobCallable v;
org.apache.hive.hcatalog.templeton.JobRequestExecutor v;
java.lang.Object v;
boolean v;
v := @this: org.apache.hive.hcatalog.templeton.JobRequestExecutor;
v := @parameter: org.apache.hive.hcatalog.templeton.JobCallable;
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.JobCallable: boolean setJobStateFailed()>();
if v != 0 goto label;
v = <org.apache.hive.hcatalog.templeton.JobRequestExecutor: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Job is already COMPLETED. Returning the result.");
v = v.<org.apache.hive.hcatalog.templeton.JobCallable: java.lang.Object returnResult>;
return v;
label:
v = <org.apache.hive.hcatalog.templeton.JobRequestExecutor: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Job status set to FAILED. Job clean up to be done by execute thread after job request is executed.");
return null;
}
static void <clinit>()
{
org.slf4j.Logger v;
org.apache.hive.hcatalog.templeton.AppConfig v;
java.lang.Class v;
boolean v, v;
v = class "Lorg/apache/hive/hcatalog/templeton/JobRequestExecutor;";
v = virtualinvoke v.<java.lang.Class: boolean desiredAssertionStatus()>();
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
<org.apache.hive.hcatalog.templeton.JobRequestExecutor: boolean $assertionsDisabled> = v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/hive/hcatalog/templeton/JobRequestExecutor;");
<org.apache.hive.hcatalog.templeton.JobRequestExecutor: org.slf4j.Logger LOG> = v;
v = staticinvoke <org.apache.hive.hcatalog.templeton.Main: org.apache.hive.hcatalog.templeton.AppConfig getAppConfigInstance()>();
<org.apache.hive.hcatalog.templeton.JobRequestExecutor: org.apache.hive.hcatalog.templeton.AppConfig appConf> = v;
return;
}
}