You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by da...@apache.org on 2016/04/16 01:12:18 UTC
hive git commit: HIVE-13498: cleardanglingscratchdir does not work if
scratchdir is not on defaultFs (Daniel Dai, reviewed by Thejas Nair)
Repository: hive
Updated Branches:
refs/heads/master d559b3475 -> 88cea1c21
HIVE-13498: cleardanglingscratchdir does not work if scratchdir is not on defaultFs (Daniel Dai, reviewed by Thejas Nair)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/88cea1c2
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/88cea1c2
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/88cea1c2
Branch: refs/heads/master
Commit: 88cea1c21d045e384c3deb628b32b93830b70e0c
Parents: d559b34
Author: Daniel Dai <da...@hortonworks.com>
Authored: Fri Apr 15 16:12:31 2016 -0700
Committer: Daniel Dai <da...@hortonworks.com>
Committed: Fri Apr 15 16:12:54 2016 -0700
----------------------------------------------------------------------
ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/88cea1c2/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 8c6c46f..344dd34 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
@@ -658,7 +658,7 @@ public class SessionState {
conf.set(HDFS_SESSION_PATH_KEY, hdfsSessionPath.toUri().toString());
// 5. hold a lock file in HDFS session dir to indicate the it is in use
if (conf.getBoolVar(HiveConf.ConfVars.HIVE_SCRATCH_DIR_LOCK)) {
- FileSystem fs = FileSystem.get(conf);
+ FileSystem fs = hdfsSessionPath.getFileSystem(conf);
hdfsSessionPathLockFile = fs.create(new Path(hdfsSessionPath, LOCK_FILE_NAME), true);
hdfsSessionPathLockFile.writeUTF("hostname: " + InetAddress.getLocalHost().getHostName() + "\n");
hdfsSessionPathLockFile.writeUTF("process: " + ManagementFactory.getRuntimeMXBean().getName() + "\n");