网络
restful
udp
JUC
Arduino基础与进阶
《红宝石》
深度信息
java8新特性
基础入门
Executor
CAS
遥感数据处理
ecmascript
cocos2d
wx.checkSession
IO-Link
贝叶斯网络
sharding5.0.0
Eolink
gradle
StreamGraph
2025/2/1 11:02:22
Flink StreamGraph生成过程
文章目录 概要SteramGraph 核心对象SteramGraph 生成过程 概要
在 Flink 中，StreamGraph 是数据流的逻辑表示，它描述了如何在 Flink 作业中执行数据流转换。StreamGraph 是 Flink 运行时生成执行计划的基础。 使用DataStream API开发的应用程序&#x…
Flink2支持提交StreamGraph到Flink集群
最近研究Flink源码的时候，发现Flink已经支持提交StreamGraph到集群了，替换掉了原来的提交JobGraph。 新增ExecutionPlan接口，将JobGraph和StreamGraph作为实现。
Flink集群Dispatcher也进行了修改，从JobGraph改成了接口Executio…