diff --git a/ql/src/java/org/apache/hadoop/hive/ql/session/OperationLog.java b/ql/src/java/org/apache/hadoop/hive/ql/session/OperationLog.java index ded4b18..1d1fc4e 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/session/OperationLog.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/session/OperationLog.java @@ -51,7 +51,7 @@ NONE, EXECUTION, PERFORMANCE, VERBOSE, UNKNOWN } - public OperationLog(String name, File file, HiveConf hiveConf) throws FileNotFoundException { + public OperationLog(String name, File file, HiveConf hiveConf) { operationName = name; logFile = new LogFile(file); @@ -133,7 +133,7 @@ public void close() { private BufferedReader in; private volatile boolean isRemoved; - LogFile(File file) throws FileNotFoundException { + LogFile(File file) { this.file = file; isRemoved = false; } @@ -157,7 +157,7 @@ synchronized void close(boolean removeLog) { if (in != null) { in.close(); } - if (!isRemoved && removeLog) { + if (!isRemoved && removeLog && file.exists()) { FileUtils.forceDelete(file); isRemoved = true; } diff --git a/service/src/java/org/apache/hive/service/cli/operation/Operation.java b/service/src/java/org/apache/hive/service/cli/operation/Operation.java index 4e78551..8d453d5 100644 --- a/service/src/java/org/apache/hive/service/cli/operation/Operation.java +++ b/service/src/java/org/apache/hive/service/cli/operation/Operation.java @@ -211,14 +211,7 @@ protected void createOperationLog() { isOperationLogEnabled = true; // create OperationLog object with above log file - try { - operationLog = new OperationLog(opHandle.toString(), operationLogFile, parentSession.getHiveConf()); - } catch (FileNotFoundException e) { - LOG.warn("Unable to instantiate OperationLog object for operation: " + - opHandle, e); - isOperationLogEnabled = false; - return; - } + operationLog = new OperationLog(opHandle.toString(), operationLogFile, parentSession.getHiveConf()); } }