原文:【异常】java.lang.ClassCastException: org.apache.spark.rdd.ShuffledRDD cannot be cast to org.apache.spark.streaming.kafka010.HasOffsetRanges

对应出异常的代码是:val offsetRanges: Array OffsetRange rdd.asInstanceOf HasOffsetRanges .offsetRanges 做foreachRDD的DStream必须是直接从KafkaUtils.createDirectStream拿到的,才能转换为kafkaRDD. 后面做其他操作的时候会把kafkaRDD转换为非kafkaRDD。 ...

2020-03-21 18:42 0 926 推荐指数:

查看详情

在maven项目中使用apache cxf中遇到异常 java.lang.ClassCastException: org.springframework.web.filter.CharacterEncodingFilter cannot be cast

使用maven虽然很方便,写一个dependency的标签就可以直接从仓库下载对应的jar包,还能处理该jar包的继承依赖关系.但是同时需要你对jar包更加了解,如果依赖关系很复杂,那么很可能会产生jar包冲突,从而使项目报一些莫名其妙的异常. 在用apache cxf的过程中就出现了这样的问题 ...

Fri Mar 06 19:01:00 CST 2015 0 3371
 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM