You are viewing a plain text version of this content. The canonical link for it is here.
Posted to mapreduce-commits@hadoop.apache.org by to...@apache.org on 2011/03/04 05:52:35 UTC

svn commit: r1077761 - in /hadoop/mapreduce/trunk: CHANGES.txt src/java/org/apache/hadoop/mapreduce/lib/chain/Chain.java

Author: tomwhite
Date: Fri Mar  4 04:52:35 2011
New Revision: 1077761

URL: http://svn.apache.org/viewvc?rev=1077761&view=rev
Log:
MAPREDUCE-1242. Chain APIs error misleading. Contributed by Harsh J Chouraria.

Modified:
    hadoop/mapreduce/trunk/CHANGES.txt
    hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/chain/Chain.java

Modified: hadoop/mapreduce/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/CHANGES.txt?rev=1077761&r1=1077760&r2=1077761&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/CHANGES.txt (original)
+++ hadoop/mapreduce/trunk/CHANGES.txt Fri Mar  4 04:52:35 2011
@@ -100,6 +100,9 @@ Trunk (unreleased changes)
     MAPREDUCE-2074. Task should fail when symlink creation fails.
     (Priyo Mustafi via tomwhite)
 
+    MAPREDUCE-1242. Chain APIs error misleading.
+    (Harsh J Chouraria via tomwhite)
+
 Release 0.22.0 - Unreleased
 
   INCOMPATIBLE CHANGES

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/chain/Chain.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/chain/Chain.java?rev=1077761&r1=1077760&r2=1077761&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/chain/Chain.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/chain/Chain.java Fri Mar  4 04:52:35 2011
@@ -692,13 +692,13 @@ public class Chain {
           + CHAIN_MAPPER_CONFIG + (index - 1));
       if (!inputKeyClass.isAssignableFrom(previousMapperConf.getClass(
           MAPPER_OUTPUT_KEY_CLASS, null))) {
-        throw new IllegalArgumentException("The Mapper output key class does"
-            + " not match the previous Mapper input key class");
+        throw new IllegalArgumentException("The specified Mapper input key class does"
+            + " not match the previous Mapper's output key class.");
       }
       if (!inputValueClass.isAssignableFrom(previousMapperConf.getClass(
           MAPPER_OUTPUT_VALUE_CLASS, null))) {
-        throw new IllegalArgumentException("The Mapper output value class"
-            + " does not match the previous Mapper input value class");
+        throw new IllegalArgumentException("The specified Mapper input value class"
+            + " does not match the previous Mapper's output value class.");
       }
     }
   }