Merge pull request #401 from balashashanka/MAHOUT-2096

MAHOUT-2096 [WIP] next() Called On Possible Empty iterator()
apache · Jan 25, 2024 · 21a14af · 21a14af
2 parents 343fc71 + 358f72a
commit 21a14af
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/...r/mr/src/main/java/org/apache/mahout/cf/taste/hadoop/als/ParallelALSFactorizationJob.java b/...r/mr/src/main/java/org/apache/mahout/cf/taste/hadoop/als/ParallelALSFactorizationJob.java
@@ -392,7 +392,11 @@ static class IDMapReducer extends Reducer<VarIntWritable,VarLongWritable,VarIntW
     @Override
     protected void reduce(VarIntWritable index, Iterable<VarLongWritable> ids, Context ctx)
       throws IOException, InterruptedException {
-      ctx.write(index, ids.iterator().next());
+      if (ids.iterator().hasNext()) {
+        ctx.write(index, ids.iterator().next());
+      } else {
+        log.debug("Iterator is empty");
+      }
     }
   }