コンストラクタJavaStreamingContext（SparkConf、Duration）は未定義です

Question

以下は私のコードです。

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。

なぜ私は上記のコンストラクタを使用するとエラーを表示します。なぜ誰に教えてもらえますか？

Answer 1

問題は、あなたがJavaStreamingContextの他Durationクラス

コンストラクタで

org.apache.spark.streaming.Durationを混乱されているが、あなたが正しいパラメータを渡していることを確認しますorg.apache.spark.streaming.Duration

public JavaStreamingContext(SparkConf conf, 
        Duration batchDuration) 

を期待しています。また、常にStackTraceをチェックしてください。多くの役に立ちます。