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

[gates]

Author: gates
Date: Fri Mar  2 19:22:52 2012
New Revision: 1296397

URL: http://svn.apache.org/viewvc?rev=1296397&view=rev
Log:
HCATALOG-280 part file name prefix with attempxxxx

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

Modified: incubator/hcatalog/trunk/CHANGES.txt
URL: 
http://svn.apache.org/viewvc/incubator/hcatalog/trunk/CHANGES.txt?rev=1296397&r1=1296396&r2=1296397&view=diff
==============================================================================
--- incubator/hcatalog/trunk/CHANGES.txt (original)
+++ incubator/hcatalog/trunk/CHANGES.txt Fri Mar  2 19:22:52 2012
@@ -68,6 +68,8 @@ Release 0.4.0 - Unreleased
   OPTIMIZATIONS
 
   BUG FIXES
+  HCAT-280 part file name prefix with attempxxxx (daijy via gates)
+
   HCAT-275 JSON SerDe issues (khorgath via gates)
 
   HCAT-278 When outputSchema doesn't match table schema wrong columns are 
returned to the user (gates)

Modified: 
incubator/hcatalog/trunk/src/java/org/apache/hcatalog/mapreduce/FileOutputFormatContainer.java
URL: 
http://svn.apache.org/viewvc/incubator/hcatalog/trunk/src/java/org/apache/hcatalog/mapreduce/FileOutputFormatContainer.java?rev=1296397&r1=1296396&r2=1296397&view=diff
==============================================================================
--- 
incubator/hcatalog/trunk/src/java/org/apache/hcatalog/mapreduce/FileOutputFormatContainer.java
 (original)
+++ 
incubator/hcatalog/trunk/src/java/org/apache/hcatalog/mapreduce/FileOutputFormatContainer.java
 Fri Mar  2 19:22:52 2012
@@ -30,6 +30,7 @@ import org.apache.hadoop.hive.metastore.
 import org.apache.hadoop.hive.metastore.api.Table;
 import org.apache.hadoop.io.Writable;
 import org.apache.hadoop.io.WritableComparable;
+import org.apache.hadoop.mapred.FileOutputFormat;
 import org.apache.hadoop.mapred.JobConf;
 import org.apache.hadoop.mapreduce.JobContext;
 import org.apache.hadoop.mapreduce.OutputCommitter;
@@ -82,7 +83,7 @@ class FileOutputFormatContainer extends 
                     getBaseOutputFormat()
                             .getRecordWriter(null,
                                                      new 
JobConf(context.getConfiguration()),
-                                                                         
context.getTaskAttemptID().toString(),
+                                                                         
FileOutputFormat.getUniqueName(new JobConf(context.getConfiguration()), "part"),
                                                                          
InternalUtil.createReporter(context)),
                 context);
         return rw;