You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@mahout.apache.org by sr...@apache.org on 2010/03/30 12:18:05 UTC

svn commit: r929067 - /lucene/mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/hadoop/item/RecommenderJob.java

Author: srowen
Date: Tue Mar 30 10:18:05 2010
New Revision: 929067

URL: http://svn.apache.org/viewvc?rev=929067&view=rev
Log:
Avoid NPE with no users file

Modified:
    lucene/mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/hadoop/item/RecommenderJob.java

Modified: lucene/mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/hadoop/item/RecommenderJob.java
URL: http://svn.apache.org/viewvc/lucene/mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/hadoop/item/RecommenderJob.java?rev=929067&r1=929066&r2=929067&view=diff
==============================================================================
--- lucene/mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/hadoop/item/RecommenderJob.java (original)
+++ lucene/mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/hadoop/item/RecommenderJob.java Tue Mar 30 10:18:05 2010
@@ -107,7 +107,9 @@ public final class RecommenderJob extend
     recommenderConf.set(RecommenderMapper.COOCCURRENCE_PATH, cooccurrencePath);
     recommenderConf.set(RecommenderMapper.ITEMID_INDEX_PATH, itemIDIndexPath);
     recommenderConf.setInt(RecommenderMapper.RECOMMENDATIONS_PER_USER, recommendationsPerUser);
-    recommenderConf.set(RecommenderMapper.USERS_FILE, usersFile);
+    if (usersFile != null) {
+      recommenderConf.set(RecommenderMapper.USERS_FILE, usersFile);
+    }
     recommenderConf.setClass("mapred.output.compression.codec", GzipCodec.class, CompressionCodec.class);
     JobClient.runJob(recommenderConf);
     return 0;