You are viewing a plain text version of this content. The canonical link for it is here.
Posted to hcatalog-commits@incubator.apache.org by ga...@apache.org on 2012/03/02 19:22:53 UTC
svn commit: r1296397 - in /incubator/hcatalog/trunk: CHANGES.txt
src/java/org/apache/hcatalog/mapreduce/FileOutputFormatContainer.java
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;