diff --git service/src/java/org/apache/hive/service/cli/CLIService.java service/src/java/org/apache/hive/service/cli/CLIService.java index 673adabe60567cd395d0156795422be55f2d3fce..424d0aae7d1f681a91d6c9891a41f7dfecb6d32e 100644 --- service/src/java/org/apache/hive/service/cli/CLIService.java +++ service/src/java/org/apache/hive/service/cli/CLIService.java @@ -381,6 +381,7 @@ public void cancelOperation(OperationHandle opHandle) @Override public void closeOperation(OperationHandle opHandle) throws HiveSQLException { + sessionManager.getLogManager().destroyOperationLog(opHandle); sessionManager.getOperationManager().getOperation(opHandle) .getParentSession().closeOperation(opHandle); LOG.debug(opHandle + ": closeOperation"); diff --git service/src/java/org/apache/hive/service/cli/session/HiveSessionImpl.java service/src/java/org/apache/hive/service/cli/session/HiveSessionImpl.java index d673628aae0f4820ac6025769c1f9d458d42f6d9..7ea0bf4fc91f85e382478cf23cd8ce2b4b3c3de4 100644 --- service/src/java/org/apache/hive/service/cli/session/HiveSessionImpl.java +++ service/src/java/org/apache/hive/service/cli/session/HiveSessionImpl.java @@ -320,6 +320,7 @@ private OperationHandle executeStatementInternal(String statement, Map