構造函數JavaStreamingContext（SparkConf，Duration）未定義

下面是我的代碼。構造函數JavaStreamingContext（SparkConf，Duration）未定義

SparkConf sparkConf = new SparkConf().setAppName("JavaKafkaWordCount").setMaster("local[*]"); 
JavaStreamingContext jssc = new JavaStreamingContext(sparkConf, new Duration(1000));

其下方和error.The構造JavaStreamingContext（SparkConf，持續時間）投擲未定義但是，當我看到火花引導時能看到下面

JavaStreamingContext（SparkConf的conf，時間batchDuration）` 創建使用SparkConf配置的JavaStreamingContext。

爲什麼當我使用上面的構造函數時顯示錯誤。誰能說出原因？

來源

2017-06-20 Manu John

通常意味着版本不匹配。 – chrylis

檢查導入並確保代碼中的'SparkConf'和'Duration'類與Spark指南中的類匹配。 – ajb

問題是你是在混淆

org.apache.spark.streaming.Duration與其他Duration類

JavaStreamingContext的構造預計org.apache.spark.streaming.Duration

public JavaStreamingContext(SparkConf conf, 
        Duration batchDuration)

確保您傳遞正確的參數。還總是檢查StackTrace它有很大幫助

來源

2017-06-20 06:15:31

構造函數JavaStreamingContext（SparkConf，Duration）未定義

回答

相關問題