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 <[email protected]> Authored: Tue Dec 6 17:18:26 2016 -0500 Committer: Chaoyu Tang <[email protected]> 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);
