MapReduce框架原理之MapTask工作機制

  一、MapTask並行度決定機制 maptask並行度決定map階段任務處理的併發度，進而影響整個job的處理速度。 一個job的map階段MapTask並行度（個數），由客戶端提交job時的切片個數決定。 例如，切兩個切片，就會生成兩個map task，切3個切片，就會生成3個map task。如圖所示：   二、MapTask工作機制 MapTask工作機制如圖所示： （1）Read階段：

>>阅读原文<<