StreamGraph转为jobGraph也是在Client完成 主要做了三件事：

    • StreamNodew 转为JobVertex
    • StreamEdge转为JobEdge
    • JobEdge和JobVertex之间创建IntermediateDataSet来连接

    org.apache.flink.client.deployment.executors.AbstractJobClusterExecutor#execute perJob生成JobGraph入口

    • org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator#createJobGraph()

    image.png