下面是我的代码。
SparkConf sparkConf = new SparkConf().setAppName("JavaKafkaWordCount").setMaster("local[*]");
JavaStreamingContext jssc = new JavaStreamingContext(sparkConf, new Duration(1000));
抛出以下错误。构造函数JavaStreamingContext（SparkConf，Duration）未定义
但是当我看到火花指南时，可以在下面看到
JavaStreamingContext（SparkConf conf，持续时间batchDuration）`
使用SparkConf配置创建JavaStreamingContext。
为什么在使用上述构造函数时显示错误？谁能告诉我为什么？
最佳答案
问题是你很困惑org.apache.spark.streaming.Duration与其他Duration类
JavaStreamingContext的构造方法期望org.apache.spark.streaming.Duration
public JavaStreamingContext(SparkConf conf,
Duration batchDuration)
确保传递正确的参数。还要经常检查StackTrace，这很有帮助
关于java - 构造函数JavaStreamingContext(SparkConf，Duration)未定义，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/44645085/