java.lang.ClassCastException:org.apache.spark.rdd.MapPartitionsRDD

再搭建的spark源码环境上,启动master与worker进程,然后将简单的单词统计代码提交到集群中,产生以下错误: 17/09/04 11:11:47 INFO DAGScheduler: ShuffleMapStage 0 (map at wordCount.scala:42) failed in 6.941 s due to Job aborted due to stage failure
相关文章
相关标签/搜索
本站公众号
   欢迎关注本站公众号,获取更多信息