diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/TaskRunner.java ql/src/java/org/apache/hadoop/hive/ql/exec/TaskRunner.java index a5554c3004..6f1ab976b8 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/TaskRunner.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/TaskRunner.java @@ -79,6 +79,7 @@ public void run() { runner = Thread.currentThread(); try { SessionState.start(ss); + LogUtils.registerLoggingContext(tsk.conf); runSequential(); } finally { try { @@ -88,6 +89,7 @@ public void run() { } catch (Exception e) { LOG.warn("Exception closing Metastore connection:" + e.getMessage()); } + LogUtils.unregisterLoggingContext(); runner = null; result.setRunning(false); }