diff --git a/service/src/java/org/apache/hive/service/cli/operation/OperationLog.java b/service/src/java/org/apache/hive/service/cli/operation/OperationLog.java index d33bcf7..1c28745 100644 --- a/service/src/java/org/apache/hive/service/cli/operation/OperationLog.java +++ b/service/src/java/org/apache/hive/service/cli/operation/OperationLog.java @@ -128,6 +128,12 @@ synchronized void write(String msg) { void remove() { try { + if (in != null) { + in.close(); + } + if (out != null) { + out.close(); + } FileUtils.forceDelete(file); isRemoved = true; } catch (Exception e) {