diff --git a/service/src/java/org/apache/hive/service/cli/session/HiveSessionImpl.java b/service/src/java/org/apache/hive/service/cli/session/HiveSessionImpl.java index a0015eb..54ee567 100644 --- a/service/src/java/org/apache/hive/service/cli/session/HiveSessionImpl.java +++ b/service/src/java/org/apache/hive/service/cli/session/HiveSessionImpl.java @@ -646,6 +646,7 @@ public void close() throws HiveSQLException { hiveHist.closeStream(); } try { + sessionState.resetThreadName(); sessionState.close(); } finally { sessionState = null; @@ -655,6 +656,7 @@ public void close() throws HiveSQLException { } finally { if (sessionState != null) { try { + sessionState.resetThreadName(); sessionState.close(); } catch (Throwable t) { LOG.warn("Error closing session", t);