spark straming 运行时的错误

查看数: 6048 | 评论数: 2 | 收藏 0

关灯 | 提示：支持键盘翻页<-左右->

发布时间: 2017-3-20 11:25

请教一个问题我从flume采集数据,传入kafka,spark straming从kafka中去消费当数据量上来之后出现该错误自己的几个猜想,kafka的topic分区什么的给小了,spark集群的内存小了?(spark给的配置是10c3g)

qcbb001 发表于 2017-3-20 15:05:44

本帖最后由 qcbb001 于 2017-3-20 15:07 编辑

org.apache.spark.sparkexception job aborted due to stage failure java.lang.arrayindexoutofboundexception

feloxx 发表于 2017-3-20 11:26:48

图片点击后可以放大

图文精华