Hi Guys, I am getting this error when I compile NetworkWordCount.scala:
nfo] Compiling 1 Scala source to /opt/unibs_test/incubator-spark-tdas/examples/target/scala-2.10/classes... [error] /opt/unibs_test/incubator-spark-tdas/examples/src/main/scala/org/apache/spark/streaming/examples/NetworkWordCount.scala:63: missing parameter type for expanded function ((x$2, x$3) => x$2.$plus(x$3)) [error] val wordCounts = words.map(x => (x, 1)).reduceByKeyAndWindow(_ + _, Seconds(30), Seconds(10)) [error] ^ [error] one error found [error] (examples/compile:compile) Compilation failed [error] Total time: 16 s, completed 07-Feb-2014 01:13:21 Could anyone help me? Thanks -- INFORMATIVA SUL TRATTAMENTO DEI DATI PERSONALI I dati utilizzati per l'invio del presente messaggio sono trattati dall'Università degli Studi di Brescia esclusivamente per finalità istituzionali. Informazioni più dettagliate anche in ordine ai diritti dell'interessato sono riposte nell'informativa generale e nelle notizie pubblicate sul sito web dell'Ateneo nella sezione "Privacy". Il contenuto di questo messaggio è rivolto unicamente alle persona cui è indirizzato e può contenere informazioni la cui riservatezza è tutelata legalmente. Ne sono vietati la riproduzione, la diffusione e l'uso in mancanza di autorizzazione del destinatario. Qualora il messaggio fosse pervenuto per errore, preghiamo di eliminarlo.
