commit c53cfae2867e3acfe9364f408dff3ab6217ee79d
author Todd Lipcon <todd@apache.org> Mon Jun 06 18:29:33 2011 +0000
committer Todd Lipcon <todd@apache.org> Mon Jun 06 18:29:33 2011 +0000
tree f4e7413f16be5894b4f9de30482e1810d2a09467
parent 630d85fb1c765e745405ed7cdd42235b951192d3

MAPREDUCE-2487. ChainReducer uses MAPPER_BY_VALUE instead of REDUCER_BY_VALUE. Contributed by Devaraj K.

git-svn-id: https://svn.apache.org/repos/asf/hadoop/mapreduce/branches/branch-0.22@1132720 13f79535-47bb-0310-9956-ffa450edef68

CHANGES.txt

diff --git a/CHANGES.txt b/CHANGES.txt
index a4f6d5f..05c8a9c 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -578,6 +578,9 @@
     MAPREDUCE-2515. MapReduce code references some deprecated options
     (Ari Rabkin via todd)
 
+    MAPREDUCE-2487. ChainReducer uses MAPPER_BY_VALUE instead of
+    REDUCER_BY_VALUE. (Devaraj K via todd)
+
 Release 0.21.1 - Unreleased
 
   NEW FEATURES

src/java/org/apache/hadoop/mapred/lib/Chain.java

diff --git a/src/java/org/apache/hadoop/mapred/lib/Chain.java b/src/java/org/apache/hadoop/mapred/lib/Chain.java
index c14e9ad..d999812 100644
--- a/src/java/org/apache/hadoop/mapred/lib/Chain.java
+++ b/src/java/org/apache/hadoop/mapred/lib/Chain.java
@@ -160,7 +160,7 @@
 
     // store in the private reducer conf the input/output classes of the reducer
     // and if it works by value or by reference
-    reducerConf.setBoolean(MAPPER_BY_VALUE, byValue);
+    reducerConf.setBoolean(REDUCER_BY_VALUE, byValue);
 
     setReducerConf(jobConf, inputKeyClass, inputValueClass, outputKeyClass,
       outputValueClass, reducerConf, prefix);