- 最近研究Flink源码的时候,发现Flink已经支持提交StreamGraph到集群了,替换掉了原来的提交JobGraph。

新增ExecutionPlan接口,将JobGraph和StreamGraph作为实现。

Flink集群Dispatcher也进行了修改,从JobGraph改成了接口ExecutionPlan,以支持StreamGraph的提交。

2. Flink2还移除了Per-Job的部署模式。
3. flink run-application 脚本命令已经不再使用,改成了 flink run yarn-application或者flink run kubernetes-application。execution.target















![IM 即时通讯系统-50-[特殊字符]cim(cross IM) 适用于开发者的分布式即时通讯系统](https://i-blog.csdnimg.cn/img_convert/796d0677346f8a7499ffdcdbfe37decf.jpeg)




