Job/Stage
。。。
Executor1
资源管理
Task
Executor2
Container(Memory/GC/CPU)
应用代码&配置
应用运行时
Driver
Executor/Task
Spark调优诊断模型
ExecutorN
应用运行时环境
用户配置spark.executor.memory=...spark.executor.cores=...
用户代码val rdd1= sc.textFile(...)val rdd2 = rdd1.reduceByKey(...).cache()rdd2.saveAsTextFile(...)