java - 构造函数 JavaStreamingContext(SparkConf, Duration) 未定义

Question

下面是我的代码:

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

它抛出以下错误:

The constructor JavaStreamingContext(SparkConf, Duration) is undefined

但是当我看到 Spark 指南时我能够看到下面的内容

JavaStreamingContext(SparkConf conf, Duration batchDuration)

使用 SparkConf 配置创建一个 JavaStreamingContext。

为什么我使用上面的构造函数时显示错误？

Answer 1

问题是你很困惑

org.apache.spark.streaming.Duration 与其他 Duration 类

JavaStreamingContext 的构造函数需要 org.apache.spark.streaming.Duration

public JavaStreamingContext(SparkConf conf,
                    Duration batchDuration)

确保您传递了正确的参数。还要经常检查 StackTrace，它很有帮助