Flink Job 的提交流程

用户提交的 Flink Job 被转换成 DAG 任务运行，StreamGraph、JobGraph、ExecutionGraph，Flink 中 JobManager 与 TaskManager，JobManager 与 Client 的交互是基于 Akka 工具包的，是通过消息驱动。在这个提交过程中还包含着 ActorSystem 的创建，JobManager 的启动，TaskManager 的启动和注册。