• 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

    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