hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hashut...@apache.org
Subject hive git commit: HIVE-13058 : Add session and operation_log directory deletion messages (Shinichi Yamashita via Ashutosh Chauhan)
Date Tue, 16 Feb 2016 23:13:08 GMT
Repository: hive
Updated Branches:
  refs/heads/master 06a361c90 -> 1b99efec6


HIVE-13058 : Add session and operation_log directory deletion messages (Shinichi Yamashita
via Ashutosh Chauhan)


Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/1b99efec
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/1b99efec
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/1b99efec

Branch: refs/heads/master
Commit: 1b99efec61aaf456f58a584bc56448d32fd65ed8
Parents: 06a361c
Author: Shinichi Yamashita <yamashitasni@oss.nttdata.co.jp>
Authored: Tue Feb 16 15:11:57 2016 -0800
Committer: Ashutosh Chauhan <hashutosh@apache.org>
Committed: Tue Feb 16 15:11:57 2016 -0800

----------------------------------------------------------------------
 ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java    | 2 ++
 .../java/org/apache/hive/service/cli/session/HiveSessionImpl.java  | 2 ++
 2 files changed, 4 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hive/blob/1b99efec/ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java
----------------------------------------------------------------------
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java b/ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java
index 2a1458e..70b2bc0 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java
@@ -747,9 +747,11 @@ public class SessionState {
   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();

http://git-wip-us.apache.org/repos/asf/hive/blob/1b99efec/service/src/java/org/apache/hive/service/cli/session/HiveSessionImpl.java
----------------------------------------------------------------------
diff --git a/service/src/java/org/apache/hive/service/cli/session/HiveSessionImpl.java b/service/src/java/org/apache/hive/service/cli/session/HiveSessionImpl.java
index 6aee80c..4aa1875 100644
--- a/service/src/java/org/apache/hive/service/cli/session/HiveSessionImpl.java
+++ b/service/src/java/org/apache/hive/service/cli/session/HiveSessionImpl.java
@@ -687,6 +687,8 @@ public class HiveSessionImpl implements HiveSession {
     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);
       }


Mime
View raw message