svn commit: r736239 - in /hadoop/core/branches/branch-0.19: CHANGES.txt src/mapred/org/apache/hadoop/mapred/ReduceTask.java

[ddas]

Author: ddas
Date: Tue Jan 20 22:30:31 2009
New Revision: 736239

URL: http://svn.apache.org/viewvc?rev=736239&view=rev
Log:
HADOOP-5002. Fixes a problem to do with the order of initialization of reduce 
task and instantiating the reducer class. Contributed by Amareshwari 
Sriramadasu.

Modified:
    hadoop/core/branches/branch-0.19/CHANGES.txt
    
hadoop/core/branches/branch-0.19/src/mapred/org/apache/hadoop/mapred/ReduceTask.java

Modified: hadoop/core/branches/branch-0.19/CHANGES.txt
URL: 
http://svn.apache.org/viewvc/hadoop/core/branches/branch-0.19/CHANGES.txt?rev=736239&r1=736238&r2=736239&view=diff
==============================================================================
--- hadoop/core/branches/branch-0.19/CHANGES.txt (original)
+++ hadoop/core/branches/branch-0.19/CHANGES.txt Tue Jan 20 22:30:31 2009
@@ -62,6 +62,10 @@
     HADOOP-4967. Fixes a race condition in the JvmManager to do with killing
     tasks. (ddas)
 
+    HADOOP-5002. Fixes a problem to do with the order of initialization of
+    reduce task and instantiating the reducer class. 
+    (Amareshwari Sriramadasu via ddas)
+
 Release 0.19.0 - 2008-11-18
 
   INCOMPATIBLE CHANGES

Modified: 
hadoop/core/branches/branch-0.19/src/mapred/org/apache/hadoop/mapred/ReduceTask.java
URL: 
http://svn.apache.org/viewvc/hadoop/core/branches/branch-0.19/src/mapred/org/apache/hadoop/mapred/ReduceTask.java?rev=736239&r1=736238&r2=736239&view=diff
==============================================================================
--- 
hadoop/core/branches/branch-0.19/src/mapred/org/apache/hadoop/mapred/ReduceTask.java
 (original)
+++ 
hadoop/core/branches/branch-0.19/src/mapred/org/apache/hadoop/mapred/ReduceTask.java
 Tue Jan 20 22:30:31 2009
@@ -334,7 +334,6 @@
   public void run(JobConf job, final TaskUmbilicalProtocol umbilical)
     throws IOException {
     job.setBoolean("mapred.skip.on", isSkipping());
-    Reducer reducer = ReflectionUtils.newInstance(job.getReducerClass(), job);
 
     if (!cleanupJob && !setupJob) {
       copyPhase = getProgress().addPhase("copy");
@@ -410,6 +409,7 @@
       };
     
     // apply reduce function
+    Reducer reducer = ReflectionUtils.newInstance(job.getReducerClass(), job);
     try {
       Class keyClass = job.getMapOutputKeyClass();
       Class valClass = job.getMapOutputValueClass();