错误而在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]");