You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tez.apache.org by ss...@apache.org on 2014/08/13 03:22:09 UTC
git commit: TEZ-1403. oah.mapred.Partitioner is not configured by
JobConf. Contributed by Navis.
Repository: tez
Updated Branches:
refs/heads/master 309e9c060 -> f24962c6e
TEZ-1403. oah.mapred.Partitioner is not configured by JobConf.
Contributed by Navis.
Project: http://git-wip-us.apache.org/repos/asf/tez/repo
Commit: http://git-wip-us.apache.org/repos/asf/tez/commit/f24962c6
Tree: http://git-wip-us.apache.org/repos/asf/tez/tree/f24962c6
Diff: http://git-wip-us.apache.org/repos/asf/tez/diff/f24962c6
Branch: refs/heads/master
Commit: f24962c6e94daf057a37399e1b551fa9d0b414be
Parents: 309e9c0
Author: Siddharth Seth <ss...@apache.org>
Authored: Tue Aug 12 18:21:37 2014 -0700
Committer: Siddharth Seth <ss...@apache.org>
Committed: Tue Aug 12 18:21:37 2014 -0700
----------------------------------------------------------------------
.../java/org/apache/tez/mapreduce/partition/MRPartitioner.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/tez/blob/f24962c6/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/partition/MRPartitioner.java
----------------------------------------------------------------------
diff --git a/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/partition/MRPartitioner.java b/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/partition/MRPartitioner.java
index f4034fd..90db734 100644
--- a/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/partition/MRPartitioner.java
+++ b/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/partition/MRPartitioner.java
@@ -62,7 +62,8 @@ public class MRPartitioner implements org.apache.tez.runtime.library.api.Partiti
if (partitions > 1) {
oldPartitioner = (org.apache.hadoop.mapred.Partitioner) ReflectionUtils.newInstance(
(Class<? extends org.apache.hadoop.mapred.Partitioner>) conf.getClass(
- "mapred.partitioner.class", org.apache.hadoop.mapred.lib.HashPartitioner.class), conf);
+ "mapred.partitioner.class", org.apache.hadoop.mapred.lib.HashPartitioner.class),
+ new JobConf(conf));
} else {
oldPartitioner = new org.apache.hadoop.mapred.Partitioner() {
@Override