錯誤而在eclipse執行例如火花流代碼JavaNetworkWordCount.java

Question

異常在線程「主」 org.apache.spark.SparkException：主URL必須在配置

在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）

Answer 1

我們需要在創建sparkconf時設置主線程> 1。

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