You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by se...@apache.org on 2016/10/11 23:10:14 UTC
[19/22] hive git commit: HIVE-14762 : Add logging while removing
scratch space (Ashutosh Chauhan via Pengcheng Xiong)
HIVE-14762 : Add logging while removing scratch space (Ashutosh Chauhan via Pengcheng Xiong)
Signed-off-by: Ashutosh Chauhan <ha...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/f4a857ca
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/f4a857ca
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/f4a857ca
Branch: refs/heads/hive-14535
Commit: f4a857ca17348cff8671e685a13ebc01b5114c0f
Parents: 17afd9b
Author: Ashutosh Chauhan <ha...@apache.org>
Authored: Wed Sep 14 16:41:07 2016 -0700
Committer: Ashutosh Chauhan <ha...@apache.org>
Committed: Tue Oct 11 14:22:54 2016 -0700
----------------------------------------------------------------------
ql/src/java/org/apache/hadoop/hive/ql/Context.java | 7 +++++--
1 file changed, 5 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/f4a857ca/ql/src/java/org/apache/hadoop/hive/ql/Context.java
----------------------------------------------------------------------
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/Context.java b/ql/src/java/org/apache/hadoop/hive/ql/Context.java
index ceb257c..838d73e 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/Context.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/Context.java
@@ -99,7 +99,7 @@ public class Context {
protected int tryCount = 0;
private TokenRewriteStream tokenRewriteStream;
- private String executionId;
+ private final String executionId;
// List of Locks for this query
protected List<HiveLock> hiveLocks;
@@ -127,7 +127,7 @@ public class Context {
private final String stagingDir;
private Heartbeater heartbeater;
-
+
private boolean skipTableMasking;
public Context(Configuration conf) throws IOException {
@@ -392,6 +392,7 @@ public class Context {
try {
Path p = entry.getValue();
FileSystem fs = p.getFileSystem(conf);
+ LOG.debug("Deleting scratch dir: {}", p);
fs.delete(p, true);
fs.cancelDeleteOnExit(p);
} catch (Exception e) {
@@ -533,6 +534,7 @@ public class Context {
if (resDir != null) {
try {
FileSystem fs = resDir.getFileSystem(conf);
+ LOG.debug("Deleting result dir: {}", resDir);
fs.delete(resDir, true);
} catch (IOException e) {
LOG.info("Context clear error: " + StringUtils.stringifyException(e));
@@ -542,6 +544,7 @@ public class Context {
if (resFile != null) {
try {
FileSystem fs = resFile.getFileSystem(conf);
+ LOG.debug("Deleting result file: {}", resFile);
fs.delete(resFile, false);
} catch (IOException e) {
LOG.info("Context clear error: " + StringUtils.stringifyException(e));