ExecutionGraph是在JobMaster中生成的
- JobVertex变为executionVertex
- intermediateResult
executionEdge
org.apache.flink.runtime.jobmaster.JobMaster#JobMaster
- org.apache.flink.runtime.jobmaster.JobMaster#createScheduler
- org.apache.flink.runtime.scheduler.SchedulerBase#createAndRestoreExecutionGraph
- org.apache.flink.runtime.scheduler.SchedulerBase#createExecutionGraph
- org.apache.flink.runtime.scheduler.SchedulerBase#createAndRestoreExecutionGraph
- org.apache.flink.runtime.jobmaster.JobMaster#createScheduler