spark streaming 报错

Caused by: java.lang.ClassNotFoundException: org.apache.spark.streaming.kafka.KafkaUtils

写回答
好问题 0 提建议
追加酬金
关注问题
分享
邀请回答
编辑收藏删除结题
收藏举报

1条回答

关注

码龄粉丝数原力等级 --

被采纳

被点赞

采纳率
离线之间 2016-08-01 12:09
关注
org.apache.spark.streaming.kafka.KafkaUtils
你没有引入这个包啊，这个包名应该是

org.apache.spark
spark-streaming-kafka_2.10
1.6.1

版本自己选择，可以去maven 下载
http://mvnrepository.com/artifact/org.apache.spark/spark-streaming-kafka_2.10

解决无用
评论打赏
分享
举报

评论

按下Enter换行，Ctrl+Enter发表内容

报告相同问题？

关注问题

Atlas关联spark插件编译报错大数据
2023-01-17 10:39

回答 3 已采纳这个是github上个人维护的spark-aql勾子程序,你的问题应该是设置高版本的spark和scala,造成了一些版本冲突,而且高版本中许多类都更新过了,当然找不到.(1)<import o
以flume为数据源的spark streaming flume spark
2022-11-08 20:23

回答 1 已采纳看下是不是还有报错classNotFoundException.应该是你导入包的时候补全少了AvroSourceProtocol相关包或者是版本依赖错了.首先看下这个类是那个jar里面的，然后再分
这个kafka在Sparkstreaming生产者出问题 kafka spark
2023-01-23 19:40

回答 2 已采纳看起来你好像少这个jar ： kafka-clients，查找一下项目里引用了没有另外就是需要你check一下你代码里是否使用了 StringDeserializer 代替了 StringSer
spark Streaming 报错 StreamingQueryException: null
2020-12-15 10:09

oliver_lorne的博客 org.apache.spark.sql.streaming.StreamingQueryException: null Current Committed Offsets: {} Current Available Offsets: {} Caused by: java.lang.NumberFormatException: null
spark和hadoop hadoop spark 大数据
2022-12-23 16:57

回答 2 已采纳集群还在启动吧，还是在安全模式，无法创建文件夹，稍等一会儿集群完全启动成功后就可以了。
java 后台查询数据使用spark Streaming处理 java spark
2017-08-04 10:06

回答 1 已采纳 http://blog.csdn.net/svmachine/article/details/52200761
关于#spark#的问题：SparkStreaming中用到了SparkSession，会话完成之后需要关闭的位置 spark 有问必答
2021-10-25 15:00

回答 2 已采纳你好，我是有问必答小助手，非常抱歉，本次您提出的有问必答问题，技术专家团超时未为您做出解答本次提问扣除的有问必答次数，将会以问答VIP体验卡（1次有问必答机会、商城购买实体图书享受95折优惠）的形式为
基于Hadoop生态SparkStreaming的大数据实时流处理平台的搭建
2018-05-28 09:18

架构文摘的博客随着公司业务发展，对大数据的获取和实时处理的要求就会越来越高，日志处理、用户行为分析、场景业务分析等等，传统的写日志方式根本满足不了业务的实时处理需求，所以本人准备开始着...
在spark streaming中实时更新mllib的ALS算法的模型遇到的问题！ mllib spark
2015-06-15 09:01

回答 1 已采纳问题已解决。。。 allData 加上cache之后异常可以解决了，这是为什么呢？其中又出现了一个错误： ![图片说明](https://img-ask.csdn.net/upload/20
【急】easyPoi使用ExcelExportUtil.exportBigExcel大数据导出报错 java
2021-08-06 17:20

回答 1 已采纳已解决，poi版本冲突问题
DeepStream python 报错：streaming stopped, reason error (-5) python 人工智能嵌入式硬件
2022-08-22 12:13

回答 2 已采纳 EGLSink改为以下：sink = Gst.ElementFactory.make("fakesink", "fakesink")
提交kafka任务到spark streaming报错：org/apache/kafka/clients/consumer/Consumer
2022-06-29 14:28

jyyy1990的博客报错org/apache/kafka/clients/consumer/Consumer 网上试了几个办法都没解决，最后把kafka-clients-0.10.0.1.jar和spark-streaming-kafka-0-10_2.11-2.4.5.jar放到master机器spark的jars目录里就不报这个错了，仅供...
sparksql遇到一个无解问题：Caused by: org.apache.hadoop.ipc.RemoteException hive spark
2022-03-03 10:52

回答 1 已采纳建议百度。猜测是没有连接上。不好意思，这个没用过
SparkStreaming中的常见错误
2020-09-14 14:57

CodeShelby的博客在将SparkSreaming中的DStreaming打印输出时常发生这种错误： Exception in thread “main” java.lang.IllegalArgumentException: requirement failed: No output operations registered, so nothing to execute ...
09.大数据技术之Spark
2022-07-13 14:07

数据带你飞的博客目前，Spark生态系统已经发展成为一个包含多个子项目的集合，其中包含SparkCore、SparkSQL、Spark Streaming、GraphX、MLib、SparkR等子项目，Spark是基于内存计算的大数据并行计算框架。除了扩展了广泛使用的 ...
没有解决我的问题, 去提问

悬赏问题

¥15 运筹学排序问题中的在线排序
¥15 关于#flink#的问题：关于docker部署flink集成hadoop的yarn，请教个问题flink启动yarn-session.sh连不上hadoop
¥30 求一段fortran代码用IVF编译运行的结果
¥15 深度学习根据CNN网络模型，搭建BP模型并训练MNIST数据集
¥15 lammps拉伸应力应变曲线分析
¥15 C++ 头文件/宏冲突问题解决
¥15 用comsol模拟大气湍流通过底部加热（温度不同）的腔体
¥50 安卓adb backup备份子用户应用数据失败
¥20 有人能用聚类分析帮我分析一下文本内容嘛
¥15 请问Lammps做复合材料拉伸模拟，应力应变曲线问题