diff --git a/ql/src/java/org/apache/hadoop/hive/ql/Driver.java b/ql/src/java/org/apache/hadoop/hive/ql/Driver.java index 0e84b6c9ab..64809a8f5a 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/Driver.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/Driver.java @@ -2003,6 +2003,7 @@ public int execute(boolean deferClose) throws CommandNeedRetryException { hook.afterExecution(qhc, executionError); } } + Hive.closeCurrent(); } catch (Exception e) { LOG.warn("Failed when invoking query after execution hook", e); }