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