Spark Core源碼分析: Spark任務模型

概述 一個Spark的Job分爲多個stage,最後一個stage會包括一個或多個ResultTask,前面的stages會包括一個或多個ShuffleMapTasks。java ResultTask執行並將結果返回給driver application。數組 ShuffleMapTask將task的output根據task的partition分離到多個buckets裏。一個ShuffleMapT
相關文章
相關標籤/搜索