spark straming 运行时的错误

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

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

图片点击后可以放大

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

图文精华