StreamingListener所属Maven依赖包查询及Spark项目依赖问题排查
问题解答
org.apache.spark.streaming.scheduler.StreamingListener类属于Spark Streaming的核心模块,你需要添加spark-streaming的基础依赖才能引入这个类。- 对应的依赖配置如下(和你现有依赖格式保持一致):
implementation "org.apache.spark:spark-streaming_${scalaVersion}:${sparkVersion}" - 你当前引入的
spark-streaming-kafka-0-10只是Spark Streaming与Kafka集成的扩展依赖,并不包含StreamingListener这类Streaming核心调度相关的类,必须单独引入spark-streaming基础依赖才能解决找不到类的问题。
内容的提问来源于stack exchange,提问作者Pavel Orekhov
相关产品推荐
相关产品推荐

