JobGraph
2025/2/1 10:43:07
Flink2支持提交StreamGraph到Flink集群
最近研究Flink源码的时候，发现Flink已经支持提交StreamGraph到集群了，替换掉了原来的提交JobGraph。 新增ExecutionPlan接口，将JobGraph和StreamGraph作为实现。
Flink集群Dispatcher也进行了修改，从JobGraph改成了接口Executio…
Flink JobGraph构建过程
文章目录 前言JobGraph创建的过程总结 前言
在StreamGraph构建过程中分析了StreamGraph的构建过程，在StreamGraph构建完毕之后会对StreamGraph进行优化构建JobGraph，然后再提交JobGraph。优化过程中，Flink会尝试将尽可能多的StreamNode聚合在…