diff --git shims/0.23/src/main/java/org/apache/hadoop/hive/shims/Hadoop23Shims.java shims/0.23/src/main/java/org/apache/hadoop/hive/shims/Hadoop23Shims.java index 2c9319f..c34a7b4 100644 --- shims/0.23/src/main/java/org/apache/hadoop/hive/shims/Hadoop23Shims.java +++ shims/0.23/src/main/java/org/apache/hadoop/hive/shims/Hadoop23Shims.java @@ -1386,12 +1386,16 @@ public void setHadoopCallerContext(String callerContext) { @Override public void setHadoopQueryContext(String callerContext) { - setHadoopCallerContext("HIVE_QUERY_ID:" + callerContext); + if (!callerContext.startsWith("HIVE_QUERY_ID")) { + setHadoopCallerContext("HIVE_QUERY_ID:" + callerContext); + } } @Override public void setHadoopSessionContext(String sessionId) { - setHadoopCallerContext("HIVE_SSN_ID:" + sessionId); + if (!callerContext.startsWith("HIVE_SSN_ID")) { + setHadoopCallerContext("HIVE_SSN_ID:" + sessionId); + } } @Override