错误而在eclipse执行例如火花流代码JavaNetworkWordCount.java

问题描述:

异常在线程“主” org.apache.spark.SparkException:主URL必须在配置错误而在eclipse执行例如火花流代码JavaNetworkWordCount.java

在org.apache进行设置。 spark.SparkContext(SparkContext.scala:185)。
在org.apache.spark.streaming.StreamingContext $ .createNewSparkContext(StreamingContext.scala:571)。
在org.apache.spark.streaming.StreamingContext(StreamingContext.scala :74)
at org.apache.spark.streaming.api.java.JavaStreamingContext。(JavaStreamingContext.scala:130)

我们需要在创建sparkconf时设置主线程> 1。

SparkConf sparkConf = new SparkConf() 
    .setAppName("JavaNetworkWordCount").setMaster("local[2]");