- org.apache.flink.runtime.jobmaster.JobMaster#startJobExecution
- org.apache.flink.runtime.jobmaster.JobMaster#resetAndStartScheduler
- org.apache.flink.runtime.scheduler.SchedulerBase#startScheduling
- org.apache.flink.runtime.scheduler.strategy.PipelinedRegionSchedulingStrategy#startScheduling
- org.apache.flink.runtime.scheduler.SchedulerOperations#allocateSlotsAndDeploy
- org.apache.flink.runtime.scheduler.DefaultScheduler#deployAll
- org.apache.flink.runtime.scheduler.DefaultExecutionVertexOperations#deploy
- org.apache.flink.runtime.jobmanager.slots.TaskManagerGateway#submitTask
- org.apache.flink.runtime.scheduler.DefaultExecutionVertexOperations#deploy
- org.apache.flink.runtime.scheduler.DefaultScheduler#deployAll
- org.apache.flink.runtime.scheduler.SchedulerOperations#allocateSlotsAndDeploy
- org.apache.flink.runtime.scheduler.strategy.PipelinedRegionSchedulingStrategy#startScheduling
- org.apache.flink.runtime.scheduler.SchedulerBase#startScheduling
- org.apache.flink.runtime.jobmaster.JobMaster#resetAndStartScheduler
Task执行
- org.apache.flink.runtime.taskexecutor.TaskExecutor#submitTask
- org.apache.flink.runtime.taskmanager.Task#startTaskThread
- org.apache.flink.runtime.taskmanager.Task#doRun
- org.apache.flink.runtime.jobgraph.tasks.AbstractInvokable#invoke
- 分为 sink source stream 等实现
- org.apache.flink.streaming.runtime.tasks.StreamTask#processInput
- org.apache.flink.streaming.runtime.io.StreamTaskNetworkInput#emitNext
- org.apache.flink.streaming.runtime.io.StreamTaskNetworkInput#processElement
- org.apache.flink.streaming.runtime.io.StreamTaskNetworkInput#emitNext
- org.apache.flink.streaming.runtime.tasks.StreamTask#processInput
- org.apache.flink.runtime.taskmanager.Task#doRun
- org.apache.flink.runtime.taskmanager.Task#startTaskThread