spark源碼系列(6) Task、shuffle執行原理

先看ShuffleMapTask#runTask override def runTask(context: TaskContext): MapStatus = { 。。。。 val manager = SparkEnv.get.shuffleManager writer = manager.getWriter[Any, Any](dep.shuffleHandle, par

>>阅读原文<<