tez-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ss...@apache.org
Subject git commit: TEZ-1112. MROutput committer should be initialized from initialized OutputFormat. Contributed by Rohini Palaniswamy.
Date Wed, 14 May 2014 15:56:37 GMT
Repository: incubator-tez
Updated Branches:
  refs/heads/master c247a3bfc -> ca7c97dc1


TEZ-1112. MROutput committer should be initialized from initialized
OutputFormat. Contributed by Rohini Palaniswamy.


Project: http://git-wip-us.apache.org/repos/asf/incubator-tez/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tez/commit/ca7c97dc
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tez/tree/ca7c97dc
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tez/diff/ca7c97dc

Branch: refs/heads/master
Commit: ca7c97dc1ee138e2a76f2a5e4bb5adf7306d5756
Parents: c247a3b
Author: Siddharth Seth <sseth@apache.org>
Authored: Wed May 14 08:56:11 2014 -0700
Committer: Siddharth Seth <sseth@apache.org>
Committed: Wed May 14 08:56:11 2014 -0700

----------------------------------------------------------------------
 .../main/java/org/apache/tez/mapreduce/output/MROutput.java | 9 +--------
 1 file changed, 1 insertion(+), 8 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/ca7c97dc/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/output/MROutput.java
----------------------------------------------------------------------
diff --git a/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/output/MROutput.java b/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/output/MROutput.java
index 170f5c8..247fcb9 100644
--- a/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/output/MROutput.java
+++ b/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/output/MROutput.java
@@ -186,14 +186,7 @@ public class MROutput extends AbstractLogicalOutput {
         LOG.debug("using new api for output committer");
       }
 
-      OutputFormat<?, ?> outputFormat = null;
-      try {
-        outputFormat = ReflectionUtils.newInstance(
-            newApiTaskAttemptContext.getOutputFormatClass(), job);
-      } catch (ClassNotFoundException cnfe) {
-        throw new IOException("Unknown OutputFormat", cnfe);
-      }
-      this.committer = outputFormat.getOutputCommitter(
+      this.committer = newOutputFormat.getOutputCommitter(
           newApiTaskAttemptContext);
     } else {
       this.committer = job.getOutputCommitter();


Mime
View raw message