Author: srowen
Date: Tue Oct 18 09:35:36 2011
New Revision: 1185544
URL: http://svn.apache.org/viewvc?rev=1185544&view=rev
Log:
Look for old and new map worker heap size arg
Modified:
mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/hadoop/item/RecommenderJob.java
Modified:
mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/hadoop/item/RecommenderJob.java
URL:
http://svn.apache.org/viewvc/mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/hadoop/item/RecommenderJob.java?rev=1185544&r1=1185543&r2=1185544&view=diff
==============================================================================
---
mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/hadoop/item/RecommenderJob.java
(original)
+++
mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/hadoop/item/RecommenderJob.java
Tue Oct 18 09:35:36 2011
@@ -255,8 +255,11 @@ public final class RecommenderJob extend
private static void setIOSort(JobContext job) {
Configuration conf = job.getConfiguration();
conf.setInt("io.sort.factor", 100);
+ String javaOpts = conf.get("mapred.map.child.java.opts"); // new arg name
+ if (javaOpts == null) {
+ javaOpts = conf.get("mapred.child.java.opts"); // old arg name
+ }
int assumedHeapSize = 512;
- String javaOpts = conf.get("mapred.child.java.opts");
if (javaOpts != null) {
Matcher m = Pattern.compile("-Xmx([0-9]+)([mMgG])").matcher(javaOpts);
if (m.find()) {
