构造函数 JavaStreamingContext(SparkConf, Duration) 未定义答案

【问题标题】：The constructor JavaStreamingContext(SparkConf, Duration) is undefined构造函数 JavaStreamingContext(SparkConf, Duration) 未定义
【发布时间】：2017-11-22 12:39:01
【问题描述】：

下面是我的代码：

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

它抛出以下错误：

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

但是当我看到 Spark 指南时，我可以看到下面

JavaStreamingContext(SparkConf conf, Duration batchDuration)

使用 SparkConf 配置创建 JavaStreamingContext。

为什么我使用上面的构造函数会报错？

【问题讨论】：

通常表示版本不匹配。
检查导入并确保代码中的 SparkConf 和 Duration 类与 Spark 指南中的类匹配。

标签： java scala apache-spark apache-kafka spark-streaming

【解决方案1】：

问题是你弄糊涂了

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

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

public JavaStreamingContext(SparkConf conf,
                    Duration batchDuration)

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

【讨论】：