diff --git ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java index 2a1458e..70b2bc0 100644 --- ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java +++ ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java @@ -747,9 +747,11 @@ public Path getTempTableSpace() { private void dropSessionPaths(Configuration conf) throws IOException { if (hdfsSessionPath != null) { hdfsSessionPath.getFileSystem(conf).delete(hdfsSessionPath, true); + LOG.info("Deleted HDFS directory: " + hdfsSessionPath); } if (localSessionPath != null) { FileSystem.getLocal(conf).delete(localSessionPath, true); + LOG.info("Deleted local directory: " + localSessionPath); } deleteTmpOutputFile(); deleteTmpErrOutputFile(); 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 6aee80c..4aa1875 100644 --- service/src/java/org/apache/hive/service/cli/session/HiveSessionImpl.java +++ service/src/java/org/apache/hive/service/cli/session/HiveSessionImpl.java @@ -687,6 +687,8 @@ private void cleanupSessionLogDir() { if (isOperationLogEnabled) { try { FileUtils.forceDelete(sessionLogDir); + LOG.info("Operation log session directory is deleted: " + + sessionLogDir.getAbsolutePath()); } catch (Exception e) { LOG.error("Failed to cleanup session log dir: " + sessionHandle, e); }