Description
JavaNetworkWordCount.java has a wrong import.
Line 28 in spark/examples/src/main/java/org/apache/spark/examples/streaming/JavaNetworkWordCount.java reads as
JavaNetworkWordCount.java
import org.apache.spark.streaming.Durations;
But according to the documentation, it should be Duration (or Seconds), not *Durations* .
Also line 60 should change accordingly because currently it reads as:
JavaNetworkWordCount.java
JavaStreamingContext ssc = new JavaStreamingContext(sparkConf, Durations.seconds(1));