Flink的Job的执行流程
| 四层 | 说明 | 备注 |
|---|---|---|
| StreamGraph | 代码生成的最初的图 | 表示程序的拓扑结构 |
| JobGraph | 将多个符合条件的节点连接为一个节点 | 减少数据在节点之间的序列化和反序列化 |
| ExecutionGraph | JobGraph的并行化版本 | 是调度层核心的数据结构 |
| PhysicalGraph | JobManager根据ExecutionGraph对Job进行调度后，在每个TaskManager上部署的Task | 不是一个具体的数据结构 |
StreamGraph
当执行main方法入口中的Evn的时候，首先生成StreamGraph
JobGraph
ExecutionGraph
在集群中执行
PhysicalGraph
这里实际在集群中运行情况
奇迹的出现往往就在再坚持一下的时候！
感谢阅读。期待点赞、分享、关注。
文章转载自beenrun，如果涉嫌侵权，请发送邮件至：contact@modb.pro进行举报，并提供相关证据，一经查实，墨天轮将立刻删除相关内容。
