diff --git service/src/java/org/apache/hive/service/cli/operation/Operation.java service/src/java/org/apache/hive/service/cli/operation/Operation.java index af5c97e28c..338a82c7a8 100644 --- service/src/java/org/apache/hive/service/cli/operation/Operation.java +++ service/src/java/org/apache/hive/service/cli/operation/Operation.java @@ -250,6 +250,9 @@ protected void afterRun() { LogUtils.unregisterLoggingContext(); // Reset back to session context after the query is done ShimLoader.getHadoopShims().setHadoopSessionContext(parentSession.getSessionState().getSessionId()); + + // To avoid mem leak in log: clean up ops log even if exception is thrown. + cleanupOperationLog(0); } /**