下面是我的代码：
SparkConf sparkConf = new SparkConf().setAppName("JavaKafkaWordCount").setMaster("local[*]");
JavaStreamingContext jssc = new JavaStreamingContext(sparkConf, new Duration(1000));其错误如下：
构造函数javastreamingcontext（sparkconf，duration）未定义
但当我看到导火索我能看到下面
JavaStreamingContext(SparkConf conf, Duration batchDuration)创建 JavaStreamingContext 使用sparkconf配置。
为什么我使用上述构造函数时会显示错误？
1条答案
按热度按时间j91ykkif1#
问题是你弄糊涂了
org.apache.spark.streaming.Duration与其他Duration班javastreamingcontext的构造函数
org.apache.spark.streaming.Duration```public JavaStreamingContext(SparkConf conf,
Duration batchDuration)