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

>>阅读原文<<