Spark任務調度

RDD Objects: 兩個RDD合併後分組、過濾 DAGScheduler: 將程序生成DAG圖，並切割stage、劃分Task（初始partition數量），將一個stage的task封裝到一個taskset,併發送至TaskScheduler TaskScheduler 這個類會向Cluster manager(Yarn)請求資源，獲取到資源後，會將TaskSet打散送至申請到的Worke

>>阅读原文<<