You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ha...@apache.org on 2016/10/11 21:38:27 UTC
hive git commit: HIVE-14828 : Cloud/S3: Stats publishing should be on
HDFS instead of S3 (Rajesh Balamohan via Ashutosh Chauhan)
Repository: hive
Updated Branches:
refs/heads/branch-1 d0f805217 -> c19837271
HIVE-14828 : Cloud/S3: Stats publishing should be on HDFS instead of S3 (Rajesh Balamohan 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/c1983727
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/c1983727
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/c1983727
Branch: refs/heads/branch-1
Commit: c1983727187be32ad6dd1b4a15ba5dfc00b55de0
Parents: d0f8052
Author: Ashutosh Chauhan <ha...@apache.org>
Authored: Tue Oct 11 14:37:56 2016 -0700
Committer: Ashutosh Chauhan <ha...@apache.org>
Committed: Tue Oct 11 14:37:56 2016 -0700
----------------------------------------------------------------------
.../java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/c1983727/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java
----------------------------------------------------------------------
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java b/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java
index 390c1c1..74f5867 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java
@@ -6674,7 +6674,8 @@ public class SemanticAnalyzer extends BaseSemanticAnalyzer {
// it should be the same as the MoveWork's sourceDir.
fileSinkDesc.setStatsAggPrefix(fileSinkDesc.getDirName().toString());
if (HiveConf.getVar(conf, HIVESTATSDBCLASS).equalsIgnoreCase(StatDB.fs.name())) {
- String statsTmpLoc = ctx.getExtTmpPathRelTo(queryTmpdir).toString();
+ String statsTmpLoc = ctx.getExtTmpPathRelTo(getParseContext().getContext()
+ .getMRScratchDir()).toString();
LOG.info("Set stats collection dir : " + statsTmpLoc);
conf.set(StatsSetupConst.STATS_TMP_LOC, statsTmpLoc);
}
@@ -9634,7 +9635,8 @@ public class SemanticAnalyzer extends BaseSemanticAnalyzer {
tsDesc.setGatherStats(false);
} else {
if (HiveConf.getVar(conf, HIVESTATSDBCLASS).equalsIgnoreCase(StatDB.fs.name())) {
- String statsTmpLoc = ctx.getExtTmpPathRelTo(tab.getPath()).toString();
+ String statsTmpLoc = ctx.getExtTmpPathRelTo(getParseContext().getContext()
+ .getMRScratchDir()).toString();
LOG.info("Set stats collection dir : " + statsTmpLoc);
conf.set(StatsSetupConst.STATS_TMP_LOC, statsTmpLoc);
}