1、简介

  最近在摸索利用sparkstreaming从kafka中准实时的读取数据,并将在读取的过程中,可以做一个简单的分析,最后将分析结果写入hbase中。

2、出现的问题

(1)将从kafka中读取数据的程序打包到服务器上运行,发现需要用kafka相关的包,因此采用assembly的方法打包即可。

(2)运行 spark-submit  --class "com.yiban.datacenter.MyDataCollection.KafkaToHbase" --master local MyDataCollection-0.0.1-SNAPSHOT-jar-with-dependencies.jar出现如下错误:

java.lang.NoClassDefFoundError: org/apache/htrace/Trace   这个错误很明显是由于无法加载对应的类,也就是没有添加相应的jar包。

分析原因:这个对应jar是一个htrace-core-3.1.0-incubating.jar 的jar包。本以为只需要在pom文件中添加对应的依赖项即可。但是我尝试的结果还是报同样的错误。

解决的方法:

  既然还是报同样的错误,于是就执行在执行命令的时候,通过命令行参数的形式指定对应的jar包的路径即可。最后运行的命令如下所示:

 spark-submit   --class "com.yiban.datacenter.MyDataCollection.KafkaToHbase  --master local   --driver-class-path  /opt/cloudera/parcels/CDH-5.4.4-1.cdh5.4.4.p0.4/jars/htrace-core-3.1.0-incubating.jar  --conf  spark.executor.extraClassPath=/opt/cloudera/parcels/CDH-5.4.4-1.cdh5.4.4.p0.4/jars/htrace-core-3.1.0-incubating.jar    MyDataCollection-0.0.1-SNAPSHOT-jar-with-dependencies.jar

同样也可以在yarn-cluster模式下运行:

 spark-submit   --class "com.yiban.datacenter.MyDataCollection.KafkaToHbase  --master  yarn-cluster  --driver-class-path  /opt/cloudera/parcels/CDH-5.4.4-1.cdh5.4.4.p0.4/jars/htrace-core-3.1.0-incubating.jar  --conf  spark.executor.extraClassPath=/opt/cloudera/parcels/CDH-5.4.4-1.cdh5.4.4.p0.4/jars/htrace-core-3.1.0-incubating.jar    MyDataCollection-0.0.1-SNAPSHOT-jar-with-dependencies.jar

转载于:https://www.cnblogs.com/ljy2013/p/5170802.html

SparkStreaming运行出现 java.lang.NoClassDefFoundError: org/apache/htrace/Trace 错误相关推荐

  1. hbase日志报java.lang.ClassNotFoundException: org.apache.htrace.SamplerBuilder的错

    环境是这样的 Hadoop-2.8.5 Hbase-2.2.4 之前查了官网,这两个版本是目前可以互相匹配的最高的版本,but启动hbase报下面这个错误 具体日志在log/下hbase-root-m ...

  2. Exception in thread “main“ java.lang.NoClassDefFoundError: org/apache/ibatis/io/Resources

    项目场景: 在学习mybatis框架的时候,刚刚学习如果查询数据库user表中的信息时 问题描述: 所有步骤都是按照教程上走的,但是运行后里面就出现了 Exception in thread &quo ...

  3. java.lang.NoClassDefFoundError: org/apache/juli/logging/LogFactory

    如果最近你也在学习SpringBoot,当项目运行时,你有可能会遇到这样的异常:java.lang.NoClassDefFoundError: org/apache/juli/logging/LogF ...

  4. java.lang.NoClassDefFoundError:org/apache/commons/io/Charsets (jsoup配合htmlunit 爬取异步加载的网页遇到的)

    最近用jsoup配合htmlunit 爬取异步加载的网页运行代码的时候,报错java.lang.NoClassDefFoundError:org/apache/commons/io/Charsets ...

  5. HBase出现java.lang.NoClassDefFoundError: org/apache/hadoop/hbase/HBaseConfiguration问题

    问题:Hbase在集群上运行报错:NoClassDefFoundError:org/apache/hadoop/hbase/HBaseConfiguration 需求:HBase使用Java创建表,打 ...

  6. maven使用mvn命令创建项目异常java.lang.NoClassDefFoundError: org/apache/commons/collections/ExtendedProperties

    命令: mvn archetype:generate -DarchetypeArtifactId=jersey-quickstart-gri zzly2 -DarchetypeGroupId=org. ...

  7. java.lang.NoClassDefFoundError: org/apache/commons/pool2/PooledObjectFactory

    用GenericObjectPool来连接postgres数据库,在pom.xml中也加入了依赖 <!-- https://mvnrepository.com/artifact/org.apac ...

  8. java.lang.NoClassDefFoundError: org/apache/geronimo/mail/util/Base64Encod——解决方案

    最近在弄通过javaMail发送信息到邮箱,老是会报这样的错误:Exception in thread "main" java.lang.NoClassDefFoundError: ...

  9. Java代码引用flink报错:java.lang.NoClassDefFoundError: org/apache/flink/streaming/util/serialization/Deseri

    我在 IDEA 环境中调试 Kafka+Flink 自己编写的例子时 代码编译都是通过的,但是进行Debug调试时,出现如下异常: java.lang.NoClassDefFoundError: or ...

最新文章

  1. vs2008中js的语法提示及修正功能(downmoonn)
  2. BCI competition IV 2b简介
  3. 图解Android - Zygote, System Server 启动分析
  4. JavaScript 专题之如何判断两个对象相等
  5. 知识点的积累(零碎的积累)
  6. protobuf流的反解析Message
  7. MySQL+Amoeba实现数据库主从复制和读写分离
  8. 一流大学计算机专业,计算机专业一流大学太难考,不妨退而求其次,看看这5所大学...
  9. HTTP Content-Disposition Explanation [ from MDN ]
  10. SQL SERVER全局变量
  11. 微信开发者工具在线调试
  12. Windows系统查看svg缩略图插件
  13. Trapcode Particular 4 for Mac(AE三维粒子插件)附序列号破解版
  14. 怎么查看本机的IP地址
  15. HenCoder Android 开发进阶:自定义 View 1-4 Canvas 对绘制的辅助 clipXXX() 和 Matrix
  16. 声笔码6.00版使用指南
  17. 桌面快捷方式自动消失
  18. 归并算法 merge
  19. 印度官方语言有几种_印度货币上有17种语言,你知道每种语言有多少人在用吗?...
  20. Python使用-错误“name ‘requests‘ is not defined”的探查

热门文章

  1. cocos2dx[3.2](5) ——入口类AppDelegate.cpp
  2. SQL Server2005如何进行数据库定期备份(转)
  3. 关于分组序号在MySQL中的实现
  4. ubuntu下vi/vim 的基本使用法
  5. 计算机基础教育德育教学,【家庭教育论文】计算机基础教学的德育教育(共2650字)...
  6. suse linux 光纤卡重置,SUSE Linux下查看光纤卡号和操作系统的版本
  7. [转贴]漫谈计算机图书翻译的四种境界
  8. 【正一专栏】内马尔要走快走、走好不送!
  9. Java经典面试题(N人循环报M个数出列)实现
  10. Leetcode 376. 摆动序列 解题思路及C++实现