You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ct...@apache.org on 2016/12/06 22:18:53 UTC
hive git commit: HIVE-15341: Get work path instead of attempted task
path in HiveHFileOutputFormat (Chaoyu Tang, reviewed by Mohit Sabharwal)
Repository: hive
Updated Branches:
refs/heads/master f317d738f -> c42bb86b8
HIVE-15341: Get work path instead of attempted task path in HiveHFileOutputFormat (Chaoyu Tang, reviewed by Mohit Sabharwal)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/c42bb86b
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/c42bb86b
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/c42bb86b
Branch: refs/heads/master
Commit: c42bb86b84bb7161792a14744bc2e7b52a0cc024
Parents: f317d73
Author: Chaoyu Tang <ct...@cloudera.com>
Authored: Tue Dec 6 17:18:26 2016 -0500
Committer: Chaoyu Tang <ct...@cloudera.com>
Committed: Tue Dec 6 17:18:26 2016 -0500
----------------------------------------------------------------------
.../java/org/apache/hadoop/hive/hbase/HiveHFileOutputFormat.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/c42bb86b/hbase-handler/src/java/org/apache/hadoop/hive/hbase/HiveHFileOutputFormat.java
----------------------------------------------------------------------
diff --git a/hbase-handler/src/java/org/apache/hadoop/hive/hbase/HiveHFileOutputFormat.java b/hbase-handler/src/java/org/apache/hadoop/hive/hbase/HiveHFileOutputFormat.java
index b6582f8..a25a96f 100644
--- a/hbase-handler/src/java/org/apache/hadoop/hive/hbase/HiveHFileOutputFormat.java
+++ b/hbase-handler/src/java/org/apache/hadoop/hive/hbase/HiveHFileOutputFormat.java
@@ -116,7 +116,7 @@ public class HiveHFileOutputFormat extends
job.getConfiguration(), progressable);
final Path outputdir = FileOutputFormat.getOutputPath(tac);
- final Path taskAttemptOutputdir = FileOutputCommitter.getTaskAttemptPath(tac, outputdir);
+ final Path taskAttemptOutputdir = new FileOutputCommitter(outputdir, tac).getWorkPath();
final org.apache.hadoop.mapreduce.RecordWriter<
ImmutableBytesWritable, KeyValue> fileWriter = getFileWriter(tac);