diff --git a/ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java b/ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java index 1e9774f..fc1f197 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java @@ -82,6 +82,7 @@ import org.apache.hadoop.hive.ql.security.authorization.plugin.HiveAuthzSessionContext; import org.apache.hadoop.hive.ql.security.authorization.plugin.HiveAuthzSessionContext.CLIENT_TYPE; import org.apache.hadoop.hive.ql.security.authorization.plugin.HiveMetastoreClientFactoryImpl; +import org.apache.hadoop.hive.ql.session.OperationLog.LoggingLevel; import org.apache.hadoop.hive.ql.util.ResourceDownloader; import org.apache.hadoop.hive.shims.HadoopShims; import org.apache.hadoop.hive.shims.ShimLoader; @@ -1043,6 +1044,7 @@ public void setLastCommand(String lastCommand) { protected Logger LOG; protected boolean isSilent; + private final OperationLog operationLog; public LogHelper(Logger LOG) { this(LOG, false); @@ -1051,6 +1053,7 @@ public LogHelper(Logger LOG) { public LogHelper(Logger LOG, boolean isSilent) { this.LOG = LOG; this.isSilent = isSilent; + this.operationLog = OperationLog.getCurrentOperationLog(); } public PrintStream getOutStream() { @@ -1100,6 +1103,11 @@ public void printInfo(String info, String detail) { if (!getIsSilent()) { getInfoStream().println(info); } + + if (operationLog != null) { + operationLog.writeOperationLog(LoggingLevel.EXECUTION, info + "\n"); + } + LOG.info(info + StringUtils.defaultString(detail)); } @@ -1115,6 +1123,9 @@ public void printError(String error) { public void printError(String error, String detail) { getErrStream().println(error); + if (operationLog != null) { + operationLog.writeOperationLog(LoggingLevel.EXECUTION, error + "\n"); + } LOG.error(error + StringUtils.defaultString(detail)); } }