Repository: hive Updated Branches: refs/heads/master 13bc529f4 -> 2b593376d
HIVE-13485 : Session id appended to thread name multiple times. (Vikram Dixit via Sergey Shelukhin) Signed-off-by: Ashutosh Chauhan <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/2b593376 Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/2b593376 Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/2b593376 Branch: refs/heads/master Commit: 2b593376d1795a738311c7dfde241cb33e35a699 Parents: 13bc529 Author: Vikram Dixit K <[email protected]> Authored: Mon Apr 11 15:05:00 2016 -0800 Committer: Ashutosh Chauhan <[email protected]> Committed: Sun May 1 18:23:09 2016 -0700 ---------------------------------------------------------------------- cli/src/java/org/apache/hadoop/hive/cli/CliDriver.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/2b593376/cli/src/java/org/apache/hadoop/hive/cli/CliDriver.java ---------------------------------------------------------------------- diff --git a/cli/src/java/org/apache/hadoop/hive/cli/CliDriver.java b/cli/src/java/org/apache/hadoop/hive/cli/CliDriver.java index f467c81..874e5aa 100644 --- a/cli/src/java/org/apache/hadoop/hive/cli/CliDriver.java +++ b/cli/src/java/org/apache/hadoop/hive/cli/CliDriver.java @@ -102,7 +102,6 @@ public class CliDriver { private final LogHelper console; protected ConsoleReader reader; private Configuration conf; - private final String originalThreadName; public CliDriver() { SessionState ss = SessionState.get(); @@ -112,7 +111,6 @@ public class CliDriver { LOG.debug("CliDriver inited with classpath {}", System.getProperty("java.class.path")); } console = new LogHelper(LOG); - originalThreadName = Thread.currentThread().getName(); } public int processCmd(String cmd) { @@ -190,7 +188,7 @@ public class CliDriver { } } - Thread.currentThread().setName(originalThreadName); + ss.resetThreadName(); return ret; } @@ -715,6 +713,7 @@ public class CliDriver { try { return executeDriver(ss, conf, oproc); } finally { + ss.resetThreadName(); ss.close(); } }
