Index: src/java/org/apache/hcatalog/mapreduce/HCatOutputFormat.java =================================================================== --- src/java/org/apache/hcatalog/mapreduce/HCatOutputFormat.java (revision 1293731) +++ src/java/org/apache/hcatalog/mapreduce/HCatOutputFormat.java (working copy) @@ -206,8 +206,9 @@ */ @Override public RecordWriter, HCatRecord> - getRecordWriter(TaskAttemptContext context - ) throws IOException, InterruptedException { + getRecordWriter(TaskAttemptContext context) + throws IOException, InterruptedException { + getOutputFormat(context).getOutputCommitter(context).setupJob(context); return getOutputFormat(context).getRecordWriter(context); }