Return-Path: X-Original-To: apmail-hive-commits-archive@www.apache.org Delivered-To: apmail-hive-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 4E45018998 for ; Tue, 16 Feb 2016 23:13:08 +0000 (UTC) Received: (qmail 56375 invoked by uid 500); 16 Feb 2016 23:13:08 -0000 Delivered-To: apmail-hive-commits-archive@hive.apache.org Received: (qmail 56326 invoked by uid 500); 16 Feb 2016 23:13:08 -0000 Mailing-List: contact commits-help@hive.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: hive-dev@hive.apache.org Delivered-To: mailing list commits@hive.apache.org Received: (qmail 56315 invoked by uid 99); 16 Feb 2016 23:13:08 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 16 Feb 2016 23:13:08 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 02F6AE0211; Tue, 16 Feb 2016 23:13:08 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: hashutosh@apache.org To: commits@hive.apache.org Message-Id: <4a7b8768c7c44f17adc0e353ccc98cbf@git.apache.org> X-Mailer: ASF-Git Admin Mailer 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 +0000 (UTC) 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 Authored: Tue Feb 16 15:11:57 2016 -0800 Committer: Ashutosh Chauhan 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); }