public class org.apache.hadoop.hive.common.LogUtils extends java.lang.Object
{
private static final java.lang.String HIVE_L4J;
private static final java.lang.String HIVE_EXEC_L4J;
private static final org.slf4j.Logger l4j;
private static final java.lang.String KEY_TO_MASK_WITH;
private static final java.lang.String MASKED_VALUE;
public static final java.lang.String SESSIONID_LOG_KEY;
public static final java.lang.String QUERYID_LOG_KEY;
public static final java.lang.String DAGID_KEY;
public static final java.lang.String OPERATIONLOG_LEVEL_KEY;
public static final java.lang.String OPERATIONLOG_LOCATION_KEY;
public void <init>()
{
org.apache.hadoop.hive.common.LogUtils v;
v := @this: org.apache.hadoop.hive.common.LogUtils;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public static java.lang.String initHiveLog4j() throws org.apache.hadoop.hive.common.LogUtils$LogInitializationException
{
java.lang.String v;
org.apache.hadoop.hive.conf.HiveConf$ConfVars v;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_LOG4J_FILE>;
v = staticinvoke <org.apache.hadoop.hive.common.LogUtils: java.lang.String initHiveLog4jCommon(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
return v;
}
public static java.lang.String initHiveExecLog4j() throws org.apache.hadoop.hive.common.LogUtils$LogInitializationException
{
java.lang.String v;
org.apache.hadoop.hive.conf.HiveConf$ConfVars v;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_EXEC_LOG4J_FILE>;
v = staticinvoke <org.apache.hadoop.hive.common.LogUtils: java.lang.String initHiveLog4jCommon(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
return v;
}
private static java.lang.String initHiveLog4jCommon(org.apache.hadoop.hive.conf.HiveConf$ConfVars) throws org.apache.hadoop.hive.common.LogUtils$LogInitializationException
{
org.apache.hadoop.hive.conf.HiveConf v;
java.lang.String v;
org.apache.hadoop.hive.conf.HiveConf$ConfVars v;
v := @parameter: org.apache.hadoop.hive.conf.HiveConf$ConfVars;
v = new org.apache.hadoop.hive.conf.HiveConf;
specialinvoke v.<org.apache.hadoop.hive.conf.HiveConf: void <init>()>();
v = staticinvoke <org.apache.hadoop.hive.common.LogUtils: java.lang.String initHiveLog4jCommon(org.apache.hadoop.hive.conf.HiveConf,org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v, v);
return v;
}
public static java.lang.String initHiveLog4jCommon(org.apache.hadoop.hive.conf.HiveConf, org.apache.hadoop.hive.conf.HiveConf$ConfVars) throws org.apache.hadoop.hive.common.LogUtils$LogInitializationException
{
long v;
org.apache.hadoop.hive.conf.HiveConf$ConfVars v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v;
boolean v, v, v, v;
org.apache.hadoop.hive.conf.HiveConf v;
java.io.File v;
v := @parameter: org.apache.hadoop.hive.conf.HiveConf;
v := @parameter: org.apache.hadoop.hive.conf.HiveConf$ConfVars;
v = staticinvoke <org.apache.hadoop.hive.conf.HiveConf: java.lang.String getVar(org.apache.hadoop.conf.Configuration,org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v, v);
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("");
if v == 0 goto label;
v = staticinvoke <org.apache.hadoop.hive.common.LogUtils: java.lang.String initHiveLog4jDefault(org.apache.hadoop.hive.conf.HiveConf,java.lang.String,org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v, "", v);
return v;
label:
v = staticinvoke <org.apache.hadoop.hive.conf.HiveConf: java.lang.String getVar(org.apache.hadoop.conf.Configuration,org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v, v);
v = new java.io.File;
specialinvoke v.<java.io.File: void <init>(java.lang.String)>(v);
v = virtualinvoke v.<java.io.File: boolean exists()>();
if v != 0 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.io.File)>(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[])>("Not able to find conf file: \u0001");
v = staticinvoke <org.apache.hadoop.hive.common.LogUtils: java.lang.String initHiveLog4jDefault(org.apache.hadoop.hive.conf.HiveConf,java.lang.String,org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v, v, v);
return v;
label:
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_EXEC_LOG4J_FILE>;
if v != v goto label;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_QUERY_ID>;
v = staticinvoke <org.apache.hadoop.hive.conf.HiveConf: java.lang.String getVar(org.apache.hadoop.conf.Configuration,org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v, v);
if v == null goto label;
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
v = v;
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v == 0 goto label;
label:
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long)>(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-\u0001");
label:
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_QUERY_ID>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf$ConfVars: java.lang.String toString()>();
staticinvoke <java.lang.System: java.lang.String setProperty(java.lang.String,java.lang.String)>(v, v);
label:
v = staticinvoke <org.apache.hadoop.hive.common.LogUtils: boolean checkAndSetAsyncLogging(org.apache.hadoop.conf.Configuration)>(v);
staticinvoke <java.lang.System: java.lang.String setProperty(java.lang.String,java.lang.String)>("isThreadContextMapInheritable", "true");
staticinvoke <org.apache.logging.log4j.core.config.Configurator: org.apache.logging.log4j.core.LoggerContext initialize(java.lang.String,java.lang.String)>(null, v);
staticinvoke <org.apache.hadoop.hive.common.LogUtils: void logConfigLocation(org.apache.hadoop.hive.conf.HiveConf)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.io.File,boolean)>(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[])>("Logging initialized using configuration in \u Async: \u0001");
return v;
}
public static boolean checkAndSetAsyncLogging(org.apache.hadoop.conf.Configuration)
{
org.apache.logging.log4j.core.impl.Log4jContextFactory v;
org.apache.hadoop.hive.conf.HiveConf$ConfVars v;
org.apache.hadoop.conf.Configuration v;
boolean v;
v := @parameter: org.apache.hadoop.conf.Configuration;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_ASYNC_LOG_ENABLED>;
v = staticinvoke <org.apache.hadoop.hive.conf.HiveConf: boolean getBoolVar(org.apache.hadoop.conf.Configuration,org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v, v);
if v == 0 goto label;
staticinvoke <java.lang.System: java.lang.String setProperty(java.lang.String,java.lang.String)>("Log4jContextSelector", "org.apache.logging.log4j.core.async.AsyncLoggerContextSelector");
v = new org.apache.logging.log4j.core.impl.Log4jContextFactory;
specialinvoke v.<org.apache.logging.log4j.core.impl.Log4jContextFactory: void <init>()>();
staticinvoke <org.apache.logging.log4j.LogManager: void setFactory(org.apache.logging.log4j.spi.LoggerContextFactory)>(v);
label:
return v;
}
private static java.lang.String initHiveLog4jDefault(org.apache.hadoop.hive.conf.HiveConf, java.lang.String, org.apache.hadoop.hive.conf.HiveConf$ConfVars) throws org.apache.hadoop.hive.common.LogUtils$LogInitializationException
{
java.net.URL v;
int[] v;
org.apache.hadoop.hive.conf.HiveConf$ConfVars v, v, v;
int v, v;
java.lang.String v, v, v, v, v, v;
boolean v;
org.apache.hadoop.hive.conf.HiveConf v;
org.apache.hadoop.hive.common.LogUtils$LogInitializationException v;
java.lang.Class v, v, v;
java.lang.ClassLoader v, v, v;
v := @parameter: org.apache.hadoop.hive.conf.HiveConf;
v := @parameter: java.lang.String;
v := @parameter: org.apache.hadoop.hive.conf.HiveConf$ConfVars;
v = null;
v = <org.apache.hadoop.hive.common.LogUtils$1: int[] $SwitchMap$org$apache$hadoop$hive$conf$HiveConf$ConfVars>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf$ConfVars: int ordinal()>();
v = v[v];
lookupswitch(v)
{
case 1: goto label;
case 2: goto label;
default: goto label;
};
label:
v = class "Lorg/apache/hadoop/hive/common/LogUtils;";
v = virtualinvoke v.<java.lang.Class: java.lang.ClassLoader getClassLoader()>();
v = virtualinvoke v.<java.lang.ClassLoader: java.net.URL getResource(java.lang.String)>("hive-exec-log4j.properties");
if v != null goto label;
v = class "Lorg/apache/hadoop/hive/common/LogUtils;";
v = virtualinvoke v.<java.lang.Class: java.lang.ClassLoader getClassLoader()>();
v = virtualinvoke v.<java.lang.ClassLoader: java.net.URL getResource(java.lang.String)>("hive-log4j.properties");
label:
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_QUERY_ID>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf$ConfVars: java.lang.String toString()>();
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_QUERY_ID>;
v = staticinvoke <org.apache.hadoop.hive.conf.HiveConf: java.lang.String getVar(org.apache.hadoop.conf.Configuration,org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v, v);
staticinvoke <java.lang.System: java.lang.String setProperty(java.lang.String,java.lang.String)>(v, v);
goto label;
label:
v = class "Lorg/apache/hadoop/hive/common/LogUtils;";
v = virtualinvoke v.<java.lang.Class: java.lang.ClassLoader getClassLoader()>();
v = virtualinvoke v.<java.lang.ClassLoader: java.net.URL getResource(java.lang.String)>("hive-log4j.properties");
label:
if v == null goto label;
v = staticinvoke <org.apache.hadoop.hive.common.LogUtils: boolean checkAndSetAsyncLogging(org.apache.hadoop.conf.Configuration)>(v);
staticinvoke <java.lang.System: java.lang.String setProperty(java.lang.String,java.lang.String)>("isThreadContextMapInheritable", "true");
v = virtualinvoke v.<java.net.URL: java.lang.String toString()>();
staticinvoke <org.apache.logging.log4j.core.config.Configurator: org.apache.logging.log4j.core.LoggerContext initialize(java.lang.String,java.lang.String)>(null, v);
staticinvoke <org.apache.hadoop.hive.common.LogUtils: void logConfigLocation(org.apache.hadoop.hive.conf.HiveConf)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.net.URL,boolean)>(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[])>("\u0001\nLogging initialized using configuration in \u Async: \u0001");
return v;
label:
v = new org.apache.hadoop.hive.common.LogUtils$LogInitializationException;
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[])>("\u0001Unable to initialize logging using hive-log4j.properties, not found on CLASSPATH!");
specialinvoke v.<org.apache.hadoop.hive.common.LogUtils$LogInitializationException: void <init>(java.lang.String)>(v);
throw v;
}
private static void logConfigLocation(org.apache.hadoop.hive.conf.HiveConf) throws org.apache.hadoop.hive.common.LogUtils$LogInitializationException
{
org.slf4j.Logger v, v, v;
java.net.URL v, v, v, v;
org.apache.hadoop.hive.conf.HiveConf v;
java.lang.String v, v, v, v;
v := @parameter: org.apache.hadoop.hive.conf.HiveConf;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: java.net.URL getHiveDefaultLocation()>();
if v == null goto label;
v = <org.apache.hadoop.hive.common.LogUtils: org.slf4j.Logger l4j>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: java.net.URL getHiveDefaultLocation()>();
v = virtualinvoke v.<java.net.URL: java.lang.String getPath()>();
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[])>("DEPRECATED: Ignoring hive-default.xml found on the CLASSPATH at \u0001");
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>(v);
label:
v = staticinvoke <org.apache.hadoop.hive.conf.HiveConf: java.net.URL getHiveSiteLocation()>();
if v != null goto label;
v = <org.apache.hadoop.hive.common.LogUtils: org.slf4j.Logger l4j>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>("hive-site.xml not found on CLASSPATH");
goto label;
label:
v = <org.apache.hadoop.hive.common.LogUtils: org.slf4j.Logger l4j>;
v = staticinvoke <org.apache.hadoop.hive.conf.HiveConf: java.net.URL getHiveSiteLocation()>();
v = virtualinvoke v.<java.net.URL: java.lang.String getPath()>();
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[])>("Using hive-site.xml found on CLASSPATH at \u0001");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
label:
return;
}
public static java.lang.String maskIfPassword(java.lang.String, java.lang.String)
{
int v, v;
java.lang.String v, v, v;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
if v == null goto label;
if v == null goto label;
v = virtualinvoke v.<java.lang.String: java.lang.String toLowerCase()>();
v = virtualinvoke v.<java.lang.String: int indexOf(java.lang.String)>("password");
v = (int) -1;
if v == v goto label;
return "###_MASKED_###";
label:
return v;
}
public static void registerLoggingContext(org.apache.hadoop.conf.Configuration)
{
org.slf4j.Logger v, v;
org.apache.hadoop.hive.conf.HiveConf$ConfVars v, v, v, v, v;
org.apache.hadoop.conf.Configuration v;
java.lang.String v, v, v, v;
boolean v;
v := @parameter: org.apache.hadoop.conf.Configuration;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_LOGGING_OPERATION_ENABLED>;
v = staticinvoke <org.apache.hadoop.hive.conf.HiveConf: boolean getBoolVar(org.apache.hadoop.conf.Configuration,org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v, v);
if v == 0 goto label;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SESSION_ID>;
v = staticinvoke <org.apache.hadoop.hive.conf.HiveConf: java.lang.String getVar(org.apache.hadoop.conf.Configuration,org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v, v);
staticinvoke <org.slf4j.MDC: void put(java.lang.String,java.lang.String)>("sessionId", v);
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_QUERY_ID>;
v = staticinvoke <org.apache.hadoop.hive.conf.HiveConf: java.lang.String getVar(org.apache.hadoop.conf.Configuration,org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v, v);
staticinvoke <org.slf4j.MDC: void put(java.lang.String,java.lang.String)>("queryId", v);
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_LOGGING_OPERATION_LEVEL>;
v = staticinvoke <org.apache.hadoop.hive.conf.HiveConf: java.lang.String getVar(org.apache.hadoop.conf.Configuration,org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v, v);
staticinvoke <org.slf4j.MDC: void put(java.lang.String,java.lang.String)>("operationLogLevel", v);
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_LOGGING_OPERATION_LOG_LOCATION>;
v = staticinvoke <org.apache.hadoop.hive.conf.HiveConf: java.lang.String getVar(org.apache.hadoop.conf.Configuration,org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v, v);
staticinvoke <org.slf4j.MDC: void put(java.lang.String,java.lang.String)>("operationLogLocation", v);
v = <org.apache.hadoop.hive.common.LogUtils: org.slf4j.Logger l4j>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Thread context registration is done.");
goto label;
label:
v = <org.apache.hadoop.hive.common.LogUtils: org.slf4j.Logger l4j>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Thread context registration is skipped.");
label:
return;
}
public static void unregisterLoggingContext()
{
org.slf4j.Logger v;
staticinvoke <org.slf4j.MDC: void remove(java.lang.String)>("sessionId");
staticinvoke <org.slf4j.MDC: void remove(java.lang.String)>("queryId");
staticinvoke <org.slf4j.MDC: void remove(java.lang.String)>("dagId");
staticinvoke <org.slf4j.MDC: void remove(java.lang.String)>("operationLogLevel");
staticinvoke <org.slf4j.MDC: void remove(java.lang.String)>("operationLogLocation");
v = <org.apache.hadoop.hive.common.LogUtils: org.slf4j.Logger l4j>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Unregistered logging context.");
return;
}
public static java.lang.String getLogFilePath()
{
java.util.Iterator v;
java.util.Collection v;
org.apache.logging.log4j.core.Appender v;
org.apache.logging.log4j.Logger v;
java.util.Map v;
java.lang.Object v;
java.lang.String v;
boolean v, v, v, v, v;
v = null;
v = staticinvoke <org.apache.logging.log4j.LogManager: org.apache.logging.log4j.Logger getRootLogger()>();
v = v instanceof org.apache.logging.log4j.core.Logger;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.logging.log4j.core.Logger: java.util.Map getAppenders()>();
v = interfaceinvoke v.<java.util.Map: java.util.Collection values()>();
v = interfaceinvoke v.<java.util.Collection: 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 = v instanceof org.apache.logging.log4j.core.appender.FileAppender;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.logging.log4j.core.appender.FileAppender: java.lang.String getFileName()>();
goto label;
label:
v = v instanceof org.apache.logging.log4j.core.appender.RollingFileAppender;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.logging.log4j.core.appender.RollingFileAppender: java.lang.String getFileName()>();
goto label;
label:
v = v instanceof org.apache.logging.log4j.core.appender.RollingRandomAccessFileAppender;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.logging.log4j.core.appender.RollingRandomAccessFileAppender: java.lang.String getFileName()>();
goto label;
label:
return v;
}
public static void putToMDC(java.lang.String, java.lang.String)
{
java.lang.String v, v;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
staticinvoke <org.slf4j.MDC: void put(java.lang.String,java.lang.String)>(v, v);
return;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/hadoop/hive/common/LogUtils;");
<org.apache.hadoop.hive.common.LogUtils: org.slf4j.Logger l4j> = v;
return;
}
}