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-14828 : Cloud/S3: Stats publishing should be on HDFS instead of S3 (Rajesh Balamohan via Ashutosh Chauhan)
Date Tue, 11 Oct 2016 21:38:27 GMT
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 <hashutosh@apache.org>
Authored: Tue Oct 11 14:37:56 2016 -0700
Committer: Ashutosh Chauhan <hashutosh@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);
       }


Mime
View raw message