hadoop-common-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From d...@apache.org
Subject svn commit: r736239 - in /hadoop/core/branches/branch-0.19: CHANGES.txt src/mapred/org/apache/hadoop/mapred/ReduceTask.java
Date Wed, 21 Jan 2009 06:30:31 GMT
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();



Mime
View raw message