You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mahout.apache.org by ad...@apache.org on 2011/02/04 09:56:45 UTC

svn commit: r1067117 - /mahout/trunk/core/src/main/java/org/apache/mahout/df/mapreduce/Builder.java

Author: adeneche
Date: Fri Feb  4 08:56:26 2011
New Revision: 1067117

URL: http://svn.apache.org/viewvc?rev=1067117&view=rev
Log:
MAHOUT-602 Removed unnecessary code and comment

Modified:
    mahout/trunk/core/src/main/java/org/apache/mahout/df/mapreduce/Builder.java

Modified: mahout/trunk/core/src/main/java/org/apache/mahout/df/mapreduce/Builder.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/main/java/org/apache/mahout/df/mapreduce/Builder.java?rev=1067117&r1=1067116&r2=1067117&view=diff
==============================================================================
--- mahout/trunk/core/src/main/java/org/apache/mahout/df/mapreduce/Builder.java (original)
+++ mahout/trunk/core/src/main/java/org/apache/mahout/df/mapreduce/Builder.java Fri Feb  4 08:56:26 2011
@@ -92,24 +92,16 @@ public abstract class Builder {
   }
   
   /**
-   * Return the value of "mapred.map.tasks". In case the 'local' runner is detected, returns 1
+   * Return the value of "mapred.map.tasks".
    * 
    * @param conf
    *          configuration
    * @return number of map tasks
    */
   public static int getNumMaps(Configuration conf) {
-    // if we are in 'local' mode, correct the number of maps
-    // or the mappers won't be able to compute the right indexes
-    String tracker = conf.get("mapred.job.tracker", "local");
-//    if ("local".equals(tracker)) {
-//      log.warn("Hadoop running in 'local' mode, only one map task will be launched");
-//      return 1;
-//    }
-    
     return conf.getInt("mapred.map.tasks", -1);
   }
-  
+
   /**
    * Used only for DEBUG purposes. if false, the mappers doesn't output anything, so the builder has nothing
    * to process