incubator-hcatalog-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ga...@apache.org
Subject svn commit: r1296398 - in /incubator/hcatalog/branches/branch-0.4: CHANGES.txt src/java/org/apache/hcatalog/mapreduce/FileOutputFormatContainer.java
Date Fri, 02 Mar 2012 19:23:40 GMT
Author: gates
Date: Fri Mar  2 19:23:40 2012
New Revision: 1296398

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

Modified:
    incubator/hcatalog/branches/branch-0.4/CHANGES.txt
    incubator/hcatalog/branches/branch-0.4/src/java/org/apache/hcatalog/mapreduce/FileOutputFormatContainer.java

Modified: incubator/hcatalog/branches/branch-0.4/CHANGES.txt
URL: http://svn.apache.org/viewvc/incubator/hcatalog/branches/branch-0.4/CHANGES.txt?rev=1296398&r1=1296397&r2=1296398&view=diff
==============================================================================
--- incubator/hcatalog/branches/branch-0.4/CHANGES.txt (original)
+++ incubator/hcatalog/branches/branch-0.4/CHANGES.txt Fri Mar  2 19:23:40 2012
@@ -56,6 +56,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/branches/branch-0.4/src/java/org/apache/hcatalog/mapreduce/FileOutputFormatContainer.java
URL: http://svn.apache.org/viewvc/incubator/hcatalog/branches/branch-0.4/src/java/org/apache/hcatalog/mapreduce/FileOutputFormatContainer.java?rev=1296398&r1=1296397&r2=1296398&view=diff
==============================================================================
--- incubator/hcatalog/branches/branch-0.4/src/java/org/apache/hcatalog/mapreduce/FileOutputFormatContainer.java
(original)
+++ incubator/hcatalog/branches/branch-0.4/src/java/org/apache/hcatalog/mapreduce/FileOutputFormatContainer.java
Fri Mar  2 19:23:40 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;



Mime
View raw message