apache spark Streaming error

Question

我正在使用apche spark（streaming）下的maven。並通過scala編程。 其實，我有一個小問題，下面的指令：

val sc= new StreamingContext(conf , Seconds(1)) 

如果我花邊的指令代碼是正確的。

這是我的全部代碼（網絡字數）：

import org.apache.spark.SparkConf 
import org.apache.spark.streaming.{Seconds, StreamingContext} 
import org.apache.spark.storage.StorageLevel 

object WordCountStreaming { 
    def main(args: Array[String]): Unit = { 
    val conf = new SparkConf() .setMaster("local") 
      .setAppName("WordCountStreaming") 
      .set("spark.driver.allowMultipleContexts","true"); val sc= new 
    StreamingContext(conf , Seconds(1)) val lines = 
     sc.socketTextStream(args(0), args(1).toInt, 
    StorageLevel.MEMORY_AND_DISK_SER) sc.start() sc.awaitTermination() 
    } 
} 

Answer 1

在這裏，你可以請儘量給人以「本地[*]」或「本地[2]」在主因爲火花流着作品如果你在本地運行它，請使用主線程中的多個線程來嘗試它。