diff --git cli/src/java/org/apache/hadoop/hive/cli/CliDriver.java cli/src/java/org/apache/hadoop/hive/cli/CliDriver.java index 2bcb56d..3db1ac7 100644 --- cli/src/java/org/apache/hadoop/hive/cli/CliDriver.java +++ cli/src/java/org/apache/hadoop/hive/cli/CliDriver.java @@ -102,7 +102,6 @@ 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 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) { @@ -192,7 +190,7 @@ public int processCmd(String cmd) { } } - Thread.currentThread().setName(originalThreadName); + ss.resetThreadName(); return ret; } @@ -720,6 +718,7 @@ public int run(String[] args) throws Exception { try { return executeDriver(ss, conf, oproc); } finally { + ss.resetThreadName(); ss.close(); } }