Flink中Graph转换流程如下：FlinkJob提交时各种类型Graph转换流程中，JobGraph是Client端形成StreamGraph后经过OperatorChain优化后形成的，然后提交给JobManager的Restserver，最终转发给JobManager的Dispatcher处理。CompletableFuturesubmitJob(JobGraphjobGraph,@RpcTimeoutTimetimeout);本文主要解析从JobGraph转换为ExecutionGraph过程，执行栈如下：Dispacher::submitJobDispacher::internal