svn commit: r1293737 - in /incubator/hcatalog/trunk: CHANGES.txt src/java/org/apache/hcatalog/mapreduce/HCatOutputFormat.java

[gates]

Author: gates
Date: Sun Feb 26 02:58:51 2012
New Revision: 1293737

URL: http://svn.apache.org/viewvc?rev=1293737&view=rev
Log:
HCATALOG-276 After merging in HCATALOG-237 related changes Pig scripts with 
more than one store fail

Modified:
    incubator/hcatalog/trunk/CHANGES.txt
    
incubator/hcatalog/trunk/src/java/org/apache/hcatalog/mapreduce/HCatOutputFormat.java

Modified: incubator/hcatalog/trunk/CHANGES.txt
URL: 
http://svn.apache.org/viewvc/incubator/hcatalog/trunk/CHANGES.txt?rev=1293737&r1=1293736&r2=1293737&view=diff
==============================================================================
--- incubator/hcatalog/trunk/CHANGES.txt (original)
+++ incubator/hcatalog/trunk/CHANGES.txt Sun Feb 26 02:58:51 2012
@@ -50,6 +50,8 @@ Trunk (unreleased changes)
   OPTIMIZATIONS
 
   BUG FIXES
+  HCAT-276 After merging in HCATALOG-237 related changes Pig scripts with more 
than one store fail (daijy via gates)
+
   HCAT-257 e2e harness not working properly after file location change (gates)
 
   HCAT-270 HCatRecord SerDe does not handle List<Map> or List<List> or 
List<lazy primitive> correctly (khorgath via gates)

Modified: 
incubator/hcatalog/trunk/src/java/org/apache/hcatalog/mapreduce/HCatOutputFormat.java
URL: 
http://svn.apache.org/viewvc/incubator/hcatalog/trunk/src/java/org/apache/hcatalog/mapreduce/HCatOutputFormat.java?rev=1293737&r1=1293736&r2=1293737&view=diff
==============================================================================
--- 
incubator/hcatalog/trunk/src/java/org/apache/hcatalog/mapreduce/HCatOutputFormat.java
 (original)
+++ 
incubator/hcatalog/trunk/src/java/org/apache/hcatalog/mapreduce/HCatOutputFormat.java
 Sun Feb 26 02:58:51 2012
@@ -206,8 +206,9 @@ public class HCatOutputFormat extends HC
      */
     @Override
     public RecordWriter<WritableComparable<?>, HCatRecord>
-      getRecordWriter(TaskAttemptContext context
-                      ) throws IOException, InterruptedException {
+        getRecordWriter(TaskAttemptContext context)
+        throws IOException, InterruptedException {
+      getOutputFormat(context).getOutputCommitter(context).setupJob(context);
       return getOutputFormat(context).getRecordWriter(context);
     }