streamingcontext无法解析为变量

31moq8wy 于 2021-05-27 发布在 Spark

关注(0)|答案(1)|浏览(379)

我正在使用以下链接与Kafka进行spark集成-
https://spark.apache.org/docs/latest/streaming-kafka-0-10-integration.html
我使用artifaceid添加了以下maven依赖项-spark-streaming-kafka-0-10_2.12除此之外，我还添加了以下jar-spark-core_2.12-3.0.1.jar、spark-streaming_2.12-3.0.1.jar
但是仍然得到错误，我遗漏了一些细节，如错误的库，丢失/错误的导入，库中的不一致等等。
ide-eclipse-jee-oxygen-2-linux-gtk-x86\u 64

apache-kafka apache-spark

来源：https://stackoverflow.com/questions/63950090/streamingcontext-can-not-be-resolved-to-a-variable

1条答案

按热度按时间

yyyllmsg1#

为了运行链接中提到的程序，您需要创建streamingcontext。

val conf = new SparkConf().setMaster("local[2]").setAppName("NetworkWordCount")
val streamingContext = new StreamingContext(conf, Seconds(1))

赞(0）回复(0）举报 2021-05-27

我来回答

streamingcontext无法解析为变量

1条答案

相关问题

热门标签

最新问答