public class org.apache.hive.hcatalog.templeton.tool.LogRetriever extends java.lang.Object
{
java.lang.String statusDir;
org.apache.hive.hcatalog.templeton.LauncherDelegator$JobType jobType;
private static final java.lang.String attemptDetailPatternInString;
private static java.util.regex.Pattern attemptDetailPattern;
private static final java.lang.String attemptLogPatternInString;
private static java.util.regex.Pattern attemptLogPattern;
private static final java.lang.String attemptIDPatternInString;
private static java.util.regex.Pattern attemptIDPattern;
private static final java.lang.String attemptStartTimePatternInString;
private static java.util.regex.Pattern attemptStartTimePattern;
private static final java.lang.String attemptEndTimePatternInString;
private static java.util.regex.Pattern attemptEndTimePattern;
private org.apache.hadoop.fs.FileSystem fs;
private org.apache.hadoop.mapred.JobClient jobClient;
private org.apache.hadoop.conf.Configuration conf;
public void <init>(java.lang.String, org.apache.hive.hcatalog.templeton.LauncherDelegator$JobType, org.apache.hadoop.conf.Configuration) throws java.io.IOException
{
org.apache.hive.hcatalog.templeton.tool.LogRetriever v;
org.apache.hadoop.fs.FileSystem v;
org.apache.hive.hcatalog.templeton.LauncherDelegator$JobType v;
org.apache.hadoop.mapred.JobConf v;
org.apache.hadoop.conf.Configuration v;
org.apache.hadoop.fs.Path v;
java.lang.String v;
java.util.regex.Pattern v, v, v, v, v;
org.apache.hadoop.mapred.JobClient v;
v := @this: org.apache.hive.hcatalog.templeton.tool.LogRetriever;
v := @parameter: java.lang.String;
v := @parameter: org.apache.hive.hcatalog.templeton.LauncherDelegator$JobType;
v := @parameter: org.apache.hadoop.conf.Configuration;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever: org.apache.hadoop.mapred.JobClient jobClient> = null;
v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever: org.apache.hadoop.conf.Configuration conf> = null;
v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever: java.lang.String statusDir> = v;
v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever: org.apache.hive.hcatalog.templeton.LauncherDelegator$JobType jobType> = v;
v = staticinvoke <java.util.regex.Pattern: java.util.regex.Pattern compile(java.lang.String)>("<a href=\"(taskdetails.jsp\\?.*?)\">");
<org.apache.hive.hcatalog.templeton.tool.LogRetriever: java.util.regex.Pattern attemptDetailPattern> = v;
v = staticinvoke <java.util.regex.Pattern: java.util.regex.Pattern compile(java.lang.String)>("Last 8KB</a><br/><a href=\"(.*?tasklog\\?attemptid=.*?)\">All</a>");
<org.apache.hive.hcatalog.templeton.tool.LogRetriever: java.util.regex.Pattern attemptLogPattern> = v;
v = staticinvoke <java.util.regex.Pattern: java.util.regex.Pattern compile(java.lang.String)>("attemptid=(.*)?&");
<org.apache.hive.hcatalog.templeton.tool.LogRetriever: java.util.regex.Pattern attemptIDPattern> = v;
v = staticinvoke <java.util.regex.Pattern: java.util.regex.Pattern compile(java.lang.String)>("<td>(\\d{1,2}-[A-Za-z]{3}-\\d{4} \\d{2}:\\d{2}:\\d{2})(<br/>)?</td>");
<org.apache.hive.hcatalog.templeton.tool.LogRetriever: java.util.regex.Pattern attemptStartTimePattern> = v;
v = staticinvoke <java.util.regex.Pattern: java.util.regex.Pattern compile(java.lang.String)>("<td>(\\d{1,2}-[A-Za-z]{3}-\\d{4} \\d{2}:\\d{2}:\\d{2}) \\(.*\\)(<br/>)?</td>");
<org.apache.hive.hcatalog.templeton.tool.LogRetriever: java.util.regex.Pattern attemptEndTimePattern> = v;
v = new org.apache.hadoop.fs.Path;
specialinvoke v.<org.apache.hadoop.fs.Path: void <init>(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.hadoop.fs.Path: org.apache.hadoop.fs.FileSystem getFileSystem(org.apache.hadoop.conf.Configuration)>(v);
v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever: org.apache.hadoop.fs.FileSystem fs> = v;
v = new org.apache.hadoop.mapred.JobClient;
v = new org.apache.hadoop.mapred.JobConf;
specialinvoke v.<org.apache.hadoop.mapred.JobConf: void <init>(org.apache.hadoop.conf.Configuration)>(v);
specialinvoke v.<org.apache.hadoop.mapred.JobClient: void <init>(org.apache.hadoop.mapred.JobConf)>(v);
v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever: org.apache.hadoop.mapred.JobClient jobClient> = v;
v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever: org.apache.hadoop.conf.Configuration conf> = v;
return;
}
public void run() throws java.io.IOException
{
org.apache.hadoop.fs.FileSystem v, v;
org.apache.hive.hcatalog.templeton.tool.PigJobIDParser v;
int[] v;
org.apache.hadoop.conf.Configuration v, v, v;
org.apache.hadoop.fs.Path v, v;
boolean v;
java.io.PrintWriter v, v;
org.apache.hive.hcatalog.templeton.LauncherDelegator$JobType v, v, v;
java.util.List v;
org.apache.hive.hcatalog.templeton.tool.JarJobIDParser v;
java.lang.Throwable v;
org.apache.hive.hcatalog.templeton.tool.JobIDParser v;
java.util.ArrayList v;
org.apache.hadoop.fs.FSDataOutputStream v;
int v, v;
java.io.OutputStreamWriter v;
java.lang.String v, v, v, v, v, v, v, v;
java.io.PrintStream v, v, v;
org.apache.hive.hcatalog.templeton.tool.LogRetriever v;
java.util.Iterator v;
java.io.IOException v, v;
org.apache.hive.hcatalog.templeton.tool.HiveJobIDParser v;
java.lang.Object v;
v := @this: org.apache.hive.hcatalog.templeton.tool.LogRetriever;
v = v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever: java.lang.String statusDir>;
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/logs");
v = v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever: org.apache.hadoop.fs.FileSystem fs>;
v = new org.apache.hadoop.fs.Path;
specialinvoke v.<org.apache.hadoop.fs.Path: void <init>(java.lang.String)>(v);
virtualinvoke v.<org.apache.hadoop.fs.FileSystem: boolean mkdirs(org.apache.hadoop.fs.Path)>(v);
v = <org.apache.hive.hcatalog.templeton.tool.LogRetriever$1: int[] $SwitchMap$org$apache$hive$hcatalog$templeton$LauncherDelegator$JobType>;
v = v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever: org.apache.hive.hcatalog.templeton.LauncherDelegator$JobType jobType>;
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.LauncherDelegator$JobType: int ordinal()>();
v = v[v];
tableswitch(v)
{
case 1: goto label;
case 2: goto label;
case 3: goto label;
case 4: goto label;
case 5: goto label;
default: goto label;
};
label:
v = new org.apache.hive.hcatalog.templeton.tool.PigJobIDParser;
v = v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever: java.lang.String statusDir>;
v = v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever: org.apache.hadoop.conf.Configuration conf>;
specialinvoke v.<org.apache.hive.hcatalog.templeton.tool.PigJobIDParser: void <init>(java.lang.String,org.apache.hadoop.conf.Configuration)>(v, v);
v = v;
goto label;
label:
v = new org.apache.hive.hcatalog.templeton.tool.HiveJobIDParser;
v = v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever: java.lang.String statusDir>;
v = v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever: org.apache.hadoop.conf.Configuration conf>;
specialinvoke v.<org.apache.hive.hcatalog.templeton.tool.HiveJobIDParser: void <init>(java.lang.String,org.apache.hadoop.conf.Configuration)>(v, v);
v = v;
goto label;
label:
v = new org.apache.hive.hcatalog.templeton.tool.JarJobIDParser;
v = v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever: java.lang.String statusDir>;
v = v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever: org.apache.hadoop.conf.Configuration conf>;
specialinvoke v.<org.apache.hive.hcatalog.templeton.tool.JarJobIDParser: void <init>(java.lang.String,org.apache.hadoop.conf.Configuration)>(v, v);
v = v;
goto label;
label:
v = <java.lang.System: java.io.PrintStream err>;
v = v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever: org.apache.hive.hcatalog.templeton.LauncherDelegator$JobType jobType>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.hive.hcatalog.templeton.LauncherDelegator$JobType)>(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[])>("Unknown job type:\u0001");
if v == null goto label;
v = v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever: org.apache.hive.hcatalog.templeton.LauncherDelegator$JobType jobType>;
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.LauncherDelegator$JobType: java.lang.String toString()>();
goto label;
label:
v = "null, only pig/hive/jar/streaming/sqoop are supported, skip logs";
label:
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
return;
label:
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = v;
label:
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.tool.JobIDParser: java.util.List parseJobID()>();
label:
goto label;
label:
v := @caughtexception;
v = <java.lang.System: java.io.PrintStream err>;
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>("Cannot retrieve jobid from log file");
virtualinvoke v.<java.io.IOException: void printStackTrace()>();
label:
v = null;
label:
v = new java.io.PrintWriter;
v = new java.io.OutputStreamWriter;
v = v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever: org.apache.hadoop.fs.FileSystem fs>;
v = new org.apache.hadoop.fs.Path;
specialinvoke v.<org.apache.hadoop.fs.Path: void <init>(java.lang.String,java.lang.String)>(v, "list.txt");
v = virtualinvoke v.<org.apache.hadoop.fs.FileSystem: org.apache.hadoop.fs.FSDataOutputStream create(org.apache.hadoop.fs.Path)>(v);
specialinvoke v.<java.io.OutputStreamWriter: void <init>(java.io.OutputStream)>(v);
specialinvoke v.<java.io.PrintWriter: void <init>(java.io.Writer)>(v);
v = 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()>();
label:
specialinvoke v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever: void logJob(java.lang.String,java.lang.String,java.io.PrintWriter)>(v, v, v);
label:
goto label;
label:
v := @caughtexception;
v = <java.lang.System: java.io.PrintStream err>;
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[])>("Cannot retrieve log for \u0001");
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
virtualinvoke v.<java.io.IOException: void printStackTrace()>();
goto label;
label:
virtualinvoke v.<java.io.PrintWriter: void close()>();
goto label;
label:
v := @caughtexception;
if v == null goto label;
virtualinvoke v.<java.io.PrintWriter: void close()>();
label:
throw v;
label:
return;
catch java.io.IOException from label to label with label;
catch java.io.IOException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
private void logJob(java.lang.String, java.lang.String, java.io.PrintWriter) throws java.io.IOException
{
org.apache.hadoop.fs.FileSystem v;
org.apache.hadoop.mapred.JobID v;
org.apache.hadoop.fs.Path v;
boolean v;
java.io.PrintWriter v;
org.apache.hadoop.mapred.RunningJob v;
java.util.List v, v;
java.lang.String[] v;
java.util.ArrayList 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;
java.io.PrintStream v, v, v, v;
org.apache.hive.hcatalog.templeton.tool.LogRetriever v;
java.util.Iterator v;
java.io.IOException v, v, v, v;
org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo$AttemptStatus v;
java.lang.Object v;
org.apache.hadoop.mapred.JobClient v;
v := @this: org.apache.hive.hcatalog.templeton.tool.LogRetriever;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.io.PrintWriter;
v = v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever: org.apache.hadoop.mapred.JobClient jobClient>;
v = staticinvoke <org.apache.hadoop.mapred.JobID: org.apache.hadoop.mapred.JobID forName(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.hadoop.mapred.JobClient: org.apache.hadoop.mapred.RunningJob getJob(org.apache.hadoop.mapred.JobID)>(v);
v = interfaceinvoke v.<org.apache.hadoop.mapred.RunningJob: java.lang.String getTrackingURL()>();
v = new org.apache.hadoop.fs.Path;
specialinvoke v.<org.apache.hadoop.fs.Path: void <init>(java.lang.String,java.lang.String)>(v, v);
v = v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever: org.apache.hadoop.fs.FileSystem fs>;
virtualinvoke v.<org.apache.hadoop.fs.FileSystem: boolean mkdirs(org.apache.hadoop.fs.Path)>(v);
label:
v = virtualinvoke v.<org.apache.hadoop.fs.Path: java.lang.String toString()>();
specialinvoke v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever: void logJobConf(java.lang.String,java.lang.String,java.lang.String)>(v, v, v);
label:
goto label;
label:
v := @caughtexception;
v = <java.lang.System: java.io.PrintStream err>;
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[])>("Cannot retrieve job.xml.html for \u0001");
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
virtualinvoke v.<java.io.IOException: void printStackTrace()>();
label:
v = interfaceinvoke v.<org.apache.hadoop.mapred.RunningJob: java.lang.String getJobName()>();
v = interfaceinvoke v.<org.apache.hadoop.mapred.RunningJob: int getJobState()>();
v = staticinvoke <org.apache.hadoop.mapred.JobStatus: java.lang.String getJobRunState(int)>(v);
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[])>("job: \u0001(name=\u,status=\u)");
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>(v);
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = newarray (java.lang.String)[4];
v[0] = "map";
v[1] = "reduce";
v[2] = "setup";
v[3] = "cleanup";
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
label:
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever: java.util.List getCompletedAttempts(java.lang.String,java.lang.String,java.lang.String)>(v, v, v);
interfaceinvoke v.<java.util.List: boolean addAll(java.util.Collection)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <java.lang.System: java.io.PrintStream err>;
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[])>("Cannot retrieve \u tasks for \u0001");
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
virtualinvoke v.<java.io.IOException: void printStackTrace()>();
label:
v = v + 1;
goto label;
label:
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever: java.util.List getFailedAttempts(java.lang.String,java.lang.String)>(v, v);
interfaceinvoke v.<java.util.List: boolean addAll(java.util.Collection)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <java.lang.System: java.io.PrintStream err>;
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[])>("Cannot retrieve failed attempts for \u0001");
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
virtualinvoke v.<java.io.IOException: void printStackTrace()>();
label:
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()>();
label:
v = virtualinvoke v.<org.apache.hadoop.fs.Path: java.lang.String toString()>();
specialinvoke v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever: void logAttempt(java.lang.String,org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo,java.lang.String)>(v, v, v);
v = v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo: java.lang.String id>;
v = v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo: java.lang.String type>;
v = v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo: org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo$AttemptStatus status>;
v = v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo: java.lang.String startTime>;
v = v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo: java.lang.String endTime>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo$AttemptStatus,java.lang.String,java.lang.String)>(v, v, 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[])>("  attempt:\u0001(type=\u,status=\u,starttime=\u,endtime=\u)");
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <java.lang.System: java.io.PrintStream err>;
v = v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo: java.lang.String id>;
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[])>("Cannot log attempt \u0001");
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
virtualinvoke v.<java.io.IOException: void printStackTrace()>();
goto label;
label:
virtualinvoke v.<java.io.PrintWriter: void println()>();
return;
catch java.io.IOException from label to label with label;
catch java.io.IOException from label to label with label;
catch java.io.IOException from label to label with label;
catch java.io.IOException from label to label with label;
}
private java.util.List[] getMatches(java.net.URL, java.util.regex.Pattern[]) throws java.io.IOException
{
java.net.URL v;
java.util.ArrayList v, v;
java.util.regex.Matcher v;
java.net.URLConnection v;
int v, v, v, v, v;
java.lang.String v, v;
java.util.ArrayList[] v;
boolean v;
org.apache.hive.hcatalog.templeton.tool.LogRetriever v;
java.util.regex.Pattern[] v;
java.io.InputStreamReader v;
java.io.BufferedReader v;
java.util.regex.Pattern v;
java.io.InputStream v;
v := @this: org.apache.hive.hcatalog.templeton.tool.LogRetriever;
v := @parameter: java.net.URL;
v := @parameter: java.util.regex.Pattern[];
v = lengthof v;
v = newarray (java.util.ArrayList)[v];
v = 0;
label:
v = lengthof v;
if v >= v goto label;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v[v] = v;
v = v + 1;
goto label;
label:
v = virtualinvoke v.<java.net.URL: java.net.URLConnection openConnection()>();
v = new java.io.BufferedReader;
v = new java.io.InputStreamReader;
v = virtualinvoke v.<java.net.URLConnection: java.io.InputStream getInputStream()>();
specialinvoke v.<java.io.InputStreamReader: void <init>(java.io.InputStream)>(v);
specialinvoke v.<java.io.BufferedReader: void <init>(java.io.Reader)>(v);
label:
v = virtualinvoke v.<java.io.BufferedReader: java.lang.String readLine()>();
if v == null goto label;
v = 0;
label:
v = lengthof v;
if v >= v goto label;
v = v[v];
v = virtualinvoke v.<java.util.regex.Pattern: java.util.regex.Matcher matcher(java.lang.CharSequence)>(v);
v = virtualinvoke v.<java.util.regex.Matcher: boolean find()>();
if v == 0 goto label;
v = v[v];
v = virtualinvoke v.<java.util.regex.Matcher: java.lang.String group(int)>(1);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
v = v + 1;
goto label;
label:
virtualinvoke v.<java.io.BufferedReader: void close()>();
return v;
}
private void logJobConf(java.lang.String, java.lang.String, java.lang.String) throws java.io.IOException
{
java.lang.Throwable v;
java.net.URL v, v;
org.apache.hadoop.fs.FileSystem v;
org.apache.hadoop.fs.FSDataOutputStream v;
java.net.URLConnection v;
int v;
java.io.OutputStreamWriter v;
org.apache.hadoop.fs.Path v;
java.lang.String v, v, v, v, v, v, v;
java.io.PrintWriter v, v;
org.apache.hive.hcatalog.templeton.tool.LogRetriever v;
java.io.InputStreamReader v;
java.io.BufferedReader v, v;
java.io.InputStream v;
v := @this: org.apache.hive.hcatalog.templeton.tool.LogRetriever;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = new java.net.URL;
specialinvoke v.<java.net.URL: void <init>(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[])>("/jobconf.jsp?jobid=\u0001");
v = new java.net.URL;
v = virtualinvoke v.<java.net.URL: java.lang.String getProtocol()>();
v = virtualinvoke v.<java.net.URL: java.lang.String getHost()>();
v = virtualinvoke v.<java.net.URL: int getPort()>();
specialinvoke v.<java.net.URL: void <init>(java.lang.String,java.lang.String,int,java.lang.String)>(v, v, v, v);
v = virtualinvoke v.<java.net.URL: java.net.URLConnection openConnection()>();
v = null;
v = null;
label:
v = new java.io.BufferedReader;
v = new java.io.InputStreamReader;
v = virtualinvoke v.<java.net.URLConnection: java.io.InputStream getInputStream()>();
specialinvoke v.<java.io.InputStreamReader: void <init>(java.io.InputStream)>(v);
specialinvoke v.<java.io.BufferedReader: void <init>(java.io.Reader)>(v);
v = v;
v = new java.io.PrintWriter;
v = new java.io.OutputStreamWriter;
v = v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever: org.apache.hadoop.fs.FileSystem fs>;
v = new org.apache.hadoop.fs.Path;
specialinvoke v.<org.apache.hadoop.fs.Path: void <init>(java.lang.String,java.lang.String)>(v, "job.xml.html");
v = virtualinvoke v.<org.apache.hadoop.fs.FileSystem: org.apache.hadoop.fs.FSDataOutputStream create(org.apache.hadoop.fs.Path)>(v);
specialinvoke v.<java.io.OutputStreamWriter: void <init>(java.io.OutputStream)>(v);
specialinvoke v.<java.io.PrintWriter: void <init>(java.io.Writer)>(v);
v = v;
label:
v = virtualinvoke v.<java.io.BufferedReader: java.lang.String readLine()>();
if v == null goto label;
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>(v);
goto label;
label:
virtualinvoke v.<java.io.BufferedReader: void close()>();
virtualinvoke v.<java.io.PrintWriter: void close()>();
goto label;
label:
v := @caughtexception;
if v == null goto label;
virtualinvoke v.<java.io.BufferedReader: void close()>();
label:
if v == null goto label;
virtualinvoke v.<java.io.PrintWriter: void close()>();
label:
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
private java.util.List getCompletedAttempts(java.lang.String, java.lang.String, java.lang.String) throws java.io.IOException
{
java.util.List[] v, v;
java.net.URL v, v, v, v;
java.util.regex.Matcher v;
boolean v, v;
java.util.regex.Pattern[] v, v;
org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo v;
java.util.List v, v, v, v, v;
java.util.regex.Pattern v, v, v, v, v;
java.util.ArrayList v;
int v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v;
org.apache.hive.hcatalog.templeton.tool.LogRetriever v;
java.util.Iterator v;
org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo$AttemptStatus v;
java.lang.Object v, v, v, v;
v := @this: org.apache.hive.hcatalog.templeton.tool.LogRetriever;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
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[])>("/jobtasks.jsp?jobid=\u0001&type=\u0001&pagenum=1&state=completed");
v = new java.net.URL;
specialinvoke v.<java.net.URL: void <init>(java.lang.String)>(v);
v = new java.net.URL;
v = virtualinvoke v.<java.net.URL: java.lang.String getProtocol()>();
v = virtualinvoke v.<java.net.URL: java.lang.String getHost()>();
v = virtualinvoke v.<java.net.URL: int getPort()>();
specialinvoke v.<java.net.URL: void <init>(java.lang.String,java.lang.String,int,java.lang.String)>(v, v, v, v);
v = newarray (java.util.regex.Pattern)[3];
v = <org.apache.hive.hcatalog.templeton.tool.LogRetriever: java.util.regex.Pattern attemptDetailPattern>;
v[0] = v;
v = <org.apache.hive.hcatalog.templeton.tool.LogRetriever: java.util.regex.Pattern attemptStartTimePattern>;
v[1] = v;
v = <org.apache.hive.hcatalog.templeton.tool.LogRetriever: java.util.regex.Pattern attemptEndTimePattern>;
v[2] = v;
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever: java.util.List[] getMatches(java.net.URL,java.util.regex.Pattern[])>(v, v);
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = 0;
label:
v = v[0];
v = interfaceinvoke v.<java.util.List: int size()>();
if v >= v goto label;
v = v[0];
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(v);
v = new java.net.URL;
v = virtualinvoke v.<java.net.URL: java.lang.String getProtocol()>();
v = virtualinvoke v.<java.net.URL: java.lang.String getHost()>();
v = virtualinvoke v.<java.net.URL: int getPort()>();
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");
specialinvoke v.<java.net.URL: void <init>(java.lang.String,java.lang.String,int,java.lang.String)>(v, v, v, v);
v = newarray (java.util.regex.Pattern)[1];
v = <org.apache.hive.hcatalog.templeton.tool.LogRetriever: java.util.regex.Pattern attemptLogPattern>;
v[0] = v;
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever: java.util.List[] getMatches(java.net.URL,java.util.regex.Pattern[])>(v, v);
v = v[0];
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 = new org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo;
specialinvoke v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo: void <init>()>();
v = new java.net.URL;
specialinvoke v.<java.net.URL: void <init>(java.lang.String)>(v);
v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo: java.net.URL baseUrl> = v;
v = v[1];
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(v);
v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo: java.lang.String startTime> = v;
v = v[2];
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(v);
v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo: java.lang.String endTime> = v;
v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo: java.lang.String type> = v;
v = <org.apache.hive.hcatalog.templeton.tool.LogRetriever: java.util.regex.Pattern attemptIDPattern>;
v = virtualinvoke v.<java.util.regex.Pattern: java.util.regex.Matcher matcher(java.lang.CharSequence)>(v);
v = virtualinvoke v.<java.util.regex.Matcher: boolean find()>();
if v == 0 goto label;
v = virtualinvoke v.<java.util.regex.Matcher: java.lang.String group(int)>(1);
v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo: java.lang.String id> = v;
label:
v = <org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo$AttemptStatus: org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo$AttemptStatus COMPLETED>;
v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo: org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo$AttemptStatus status> = v;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = v + 1;
goto label;
label:
return v;
}
private java.util.List getFailedAttempts(java.lang.String, java.lang.String) throws java.io.IOException
{
java.util.List[] v, v;
java.net.URL v, v, v, v;
java.util.regex.Matcher v;
boolean v, v, v, v, v;
java.util.regex.Pattern[] v, v;
org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo v;
java.util.List v, v, v, v, v;
java.util.regex.Pattern v, v, v, v, v;
java.util.ArrayList v, v;
int v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v;
org.apache.hive.hcatalog.templeton.tool.LogRetriever v;
java.util.Iterator v, v;
org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo$AttemptStatus v, v;
java.lang.Object v, v, v, v, v;
v := @this: org.apache.hive.hcatalog.templeton.tool.LogRetriever;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
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[])>("/jobfailures.jsp?jobid=\u0001&kind=all&cause=failed");
v = new java.net.URL;
specialinvoke v.<java.net.URL: void <init>(java.lang.String)>(v);
v = new java.net.URL;
v = virtualinvoke v.<java.net.URL: java.lang.String getProtocol()>();
v = virtualinvoke v.<java.net.URL: java.lang.String getHost()>();
v = virtualinvoke v.<java.net.URL: int getPort()>();
specialinvoke v.<java.net.URL: void <init>(java.lang.String,java.lang.String,int,java.lang.String)>(v, v, v, v);
v = newarray (java.util.regex.Pattern)[1];
v = <org.apache.hive.hcatalog.templeton.tool.LogRetriever: java.util.regex.Pattern attemptDetailPattern>;
v[0] = v;
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever: java.util.List[] getMatches(java.net.URL,java.util.regex.Pattern[])>(v, v);
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = v[0];
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.<java.util.List: boolean contains(java.lang.Object)>(v);
if v != 0 goto label;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
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 = new java.net.URL;
v = virtualinvoke v.<java.net.URL: java.lang.String getProtocol()>();
v = virtualinvoke v.<java.net.URL: java.lang.String getHost()>();
v = virtualinvoke v.<java.net.URL: int getPort()>();
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");
specialinvoke v.<java.net.URL: void <init>(java.lang.String,java.lang.String,int,java.lang.String)>(v, v, v, v);
v = newarray (java.util.regex.Pattern)[3];
v = <org.apache.hive.hcatalog.templeton.tool.LogRetriever: java.util.regex.Pattern attemptLogPattern>;
v[0] = v;
v = <org.apache.hive.hcatalog.templeton.tool.LogRetriever: java.util.regex.Pattern attemptStartTimePattern>;
v[1] = v;
v = <org.apache.hive.hcatalog.templeton.tool.LogRetriever: java.util.regex.Pattern attemptEndTimePattern>;
v[2] = v;
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever: java.util.List[] getMatches(java.net.URL,java.util.regex.Pattern[])>(v, v);
v = 0;
label:
v = v[0];
v = interfaceinvoke v.<java.util.List: int size()>();
if v >= v goto label;
v = v[0];
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(v);
v = new org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo;
specialinvoke v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo: void <init>()>();
v = new java.net.URL;
specialinvoke v.<java.net.URL: void <init>(java.lang.String)>(v);
v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo: java.net.URL baseUrl> = v;
v = v[1];
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(v);
v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo: java.lang.String startTime> = v;
v = v[2];
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(v);
v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo: java.lang.String endTime> = v;
v = <org.apache.hive.hcatalog.templeton.tool.LogRetriever: java.util.regex.Pattern attemptIDPattern>;
v = virtualinvoke v.<java.util.regex.Pattern: java.util.regex.Matcher matcher(java.lang.CharSequence)>(v);
v = virtualinvoke v.<java.util.regex.Matcher: boolean find()>();
if v == 0 goto label;
v = virtualinvoke v.<java.util.regex.Matcher: java.lang.String group(int)>(1);
v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo: java.lang.String id> = v;
label:
v = v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo: java.lang.String id>;
v = virtualinvoke v.<java.lang.String: boolean contains(java.lang.CharSequence)>("_r_");
if v == 0 goto label;
v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo: java.lang.String type> = "reduce";
label:
v = <org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo$AttemptStatus: org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo$AttemptStatus COMPLETED>;
v = <org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo$AttemptStatus: org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo$AttemptStatus FAILED>;
v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo: org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo$AttemptStatus status> = v;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
return v;
}
private void logAttempt(java.lang.String, org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo, java.lang.String) throws java.io.IOException
{
java.net.URL v, v, v, v;
org.apache.hadoop.fs.FileSystem v, v;
org.apache.hadoop.fs.Path v, v;
java.io.PrintWriter v, v;
org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo v;
java.lang.Throwable v;
java.lang.String[] v;
org.apache.hadoop.fs.FSDataOutputStream v;
java.net.URLConnection v;
int v, v, v;
java.io.OutputStreamWriter v;
java.lang.String v, v, v, v, v, v, v, v, v, v;
org.apache.hive.hcatalog.templeton.tool.LogRetriever v;
java.io.InputStreamReader v;
java.io.BufferedReader v, v;
java.io.InputStream v;
v := @this: org.apache.hive.hcatalog.templeton.tool.LogRetriever;
v := @parameter: java.lang.String;
v := @parameter: org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo;
v := @parameter: java.lang.String;
v = new org.apache.hadoop.fs.Path;
v = v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo: java.lang.String id>;
specialinvoke v.<org.apache.hadoop.fs.Path: void <init>(java.lang.String,java.lang.String)>(v, v);
v = v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever: org.apache.hadoop.fs.FileSystem fs>;
virtualinvoke v.<org.apache.hadoop.fs.FileSystem: boolean mkdirs(org.apache.hadoop.fs.Path)>(v);
v = newarray (java.lang.String)[3];
v[0] = "stderr";
v[1] = "stdout";
v[2] = "syslog";
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo: java.lang.String id>;
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[])>("tasklog?attemptid=\u0001&plaintext=true&filter=\u0001");
v = new java.net.URL;
v = v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo: java.net.URL baseUrl>;
v = virtualinvoke v.<java.net.URL: java.lang.String getProtocol()>();
v = v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo: java.net.URL baseUrl>;
v = virtualinvoke v.<java.net.URL: java.lang.String getHost()>();
v = v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever$AttemptInfo: java.net.URL baseUrl>;
v = virtualinvoke v.<java.net.URL: int getPort()>();
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");
specialinvoke v.<java.net.URL: void <init>(java.lang.String,java.lang.String,int,java.lang.String)>(v, v, v, v);
v = virtualinvoke v.<java.net.URL: java.net.URLConnection openConnection()>();
v = null;
v = null;
label:
v = new java.io.BufferedReader;
v = new java.io.InputStreamReader;
v = virtualinvoke v.<java.net.URLConnection: java.io.InputStream getInputStream()>();
specialinvoke v.<java.io.InputStreamReader: void <init>(java.io.InputStream)>(v);
specialinvoke v.<java.io.BufferedReader: void <init>(java.io.Reader)>(v);
v = v;
v = new java.io.PrintWriter;
v = new java.io.OutputStreamWriter;
v = v.<org.apache.hive.hcatalog.templeton.tool.LogRetriever: org.apache.hadoop.fs.FileSystem fs>;
v = new org.apache.hadoop.fs.Path;
specialinvoke v.<org.apache.hadoop.fs.Path: void <init>(org.apache.hadoop.fs.Path,java.lang.String)>(v, v);
v = virtualinvoke v.<org.apache.hadoop.fs.FileSystem: org.apache.hadoop.fs.FSDataOutputStream create(org.apache.hadoop.fs.Path)>(v);
specialinvoke v.<java.io.OutputStreamWriter: void <init>(java.io.OutputStream)>(v);
specialinvoke v.<java.io.PrintWriter: void <init>(java.io.Writer)>(v);
v = v;
label:
v = virtualinvoke v.<java.io.BufferedReader: java.lang.String readLine()>();
if v == null goto label;
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>(v);
goto label;
label:
virtualinvoke v.<java.io.BufferedReader: void close()>();
virtualinvoke v.<java.io.PrintWriter: void close()>();
goto label;
label:
v := @caughtexception;
if v == null goto label;
virtualinvoke v.<java.io.BufferedReader: void close()>();
label:
if v == null goto label;
virtualinvoke v.<java.io.PrintWriter: void close()>();
label:
throw v;
label:
v = v + 1;
goto label;
label:
return;
catch java.lang.Throwable from label to label with label;
}
static void <clinit>()
{
<org.apache.hive.hcatalog.templeton.tool.LogRetriever: java.util.regex.Pattern attemptDetailPattern> = null;
<org.apache.hive.hcatalog.templeton.tool.LogRetriever: java.util.regex.Pattern attemptLogPattern> = null;
<org.apache.hive.hcatalog.templeton.tool.LogRetriever: java.util.regex.Pattern attemptIDPattern> = null;
<org.apache.hive.hcatalog.templeton.tool.LogRetriever: java.util.regex.Pattern attemptStartTimePattern> = null;
<org.apache.hive.hcatalog.templeton.tool.LogRetriever: java.util.regex.Pattern attemptEndTimePattern> = null;
return;
}
}