From ca2964200e430947fdf7181efce2d3da8c70510f Mon Sep 17 00:00:00 2001
From: Abin Joy <abinmj656@gmail.com>
Date: Fri, 19 Jul 2019 20:25:27 +0530
Subject: [PATCH] Update WordCount.java

Arrays.asList<String> returns List<String>, which needs to convert to Iterator<String>.
---
 .../java/com/oreilly/learningsparkexamples/java/WordCount.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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<String, Integer> counts = rdd.flatMap(
       new FlatMapFunction<String, String>() {
         public Iterable<String> call(String x) {
-          return Arrays.asList(x.split(" "));
+          return Arrays.asList(x.split(" ")).iterator();
         }}).mapToPair(new PairFunction<String, String, Integer>(){
             public Tuple2<String, Integer> call(String x){
               return new Tuple2(x, 1);