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 2017/02/27 20:24:21 UTC
[19/20] hive git commit: HIVE-14990 : run all tests for MM tables and
fix the issues that are found - a DP stats issue (Sergey Shelukhin)
HIVE-14990 : run all tests for MM tables and fix the issues that are found - a DP stats issue (Sergey Shelukhin)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/7cc741c6
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/7cc741c6
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/7cc741c6
Branch: refs/heads/hive-14535
Commit: 7cc741c6146774d47d77e6c2ab213f4d2cd6b049
Parents: 693b856
Author: Sergey Shelukhin <se...@apache.org>
Authored: Mon Feb 27 12:18:00 2017 -0800
Committer: Sergey Shelukhin <se...@apache.org>
Committed: Mon Feb 27 12:18:00 2017 -0800
----------------------------------------------------------------------
ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java | 2 +-
ql/src/java/org/apache/hadoop/hive/ql/exec/MoveTask.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/7cc741c6/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java
----------------------------------------------------------------------
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java
index 530b364..37c3a96 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java
@@ -960,7 +960,7 @@ public class FileSinkOperator extends TerminalOperator<FileSinkDesc> implements
fsp2.configureDynPartPath(dirName, !conf.isMmTable() && isUnionDp ? unionPath : null);
Utilities.LOG14535.info("creating new paths " + System.identityHashCode(fsp2) + " for "
+ dirName + ", childSpec " + unionPath + ": tmpPath " + fsp2.getTmpPath()
- + ", task path " + fsp2.getTaskOutputTempPath(), new Exception());
+ + ", task path " + fsp2.getTaskOutputTempPath());
if(!conf.getDpSortState().equals(DPSortState.PARTITION_BUCKET_SORTED)) {
createBucketFiles(fsp2);
valToPaths.put(dirName, fsp2);
http://git-wip-us.apache.org/repos/asf/hive/blob/7cc741c6/ql/src/java/org/apache/hadoop/hive/ql/exec/MoveTask.java
----------------------------------------------------------------------
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/MoveTask.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/MoveTask.java
index b3e6f4e..51a8a79 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/exec/MoveTask.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/MoveTask.java
@@ -453,7 +453,7 @@ public class MoveTask extends Task<MoveWork> implements Serializable {
// publish DP columns to its subscribers
if (dps != null && dps.size() > 0) {
- pushFeed(FeedType.DYNAMIC_PARTITIONS, dps);
+ pushFeed(FeedType.DYNAMIC_PARTITIONS, dp.values());
}
String loadTime = "\t Time taken to load dynamic partitions: " +