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 RecordWriter getHiveRecordWriter( 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);