diff --git a/src/main/java/com/oreilly/learningsparkexamples/java/WordCount.java b/src/main/java/com/oreilly/learningsparkexamples/java/WordCount.java index dd0ce0f5..0b4da754 100644 --- a/src/main/java/com/oreilly/learningsparkexamples/java/WordCount.java +++ b/src/main/java/com/oreilly/learningsparkexamples/java/WordCount.java @@ -28,7 +28,7 @@ public static void main(String[] args) throws Exception { JavaPairRDD counts = rdd.flatMap( new FlatMapFunction() { public Iterable call(String x) { - return Arrays.asList(x.split(" ")); + return Arrays.asList(x.split(" ")).iterator(); }}).mapToPair(new PairFunction(){ public Tuple2 call(String x){ return new Tuple2(x, 1);