DRIVER NODE
SparkContext
DAGScheduler
WORKER NODE 1
Executor
Task
WORKER NODE 2
Executor
Task
WORKER NODE 3
Executor
Task