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 78bbb1f..23b8a96 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 @@ -417,7 +417,7 @@ public void resetThreadName() { if (currThreadName.contains(logPrefix)) { final String[] names = currThreadName.split(logPrefix); LOG.info("Resetting thread name to {}", names[names.length - 1]); - Thread.currentThread().setName(names[names.length - 1]); + Thread.currentThread().setName(names[names.length - 1].trim()); } }