Open utterances-bot opened 2 years ago
前面的文章我们介绍了 StreamGraph 的生成,这个实际上只对应 Flink 作业在逻辑上的执行计划图。Flink 会进一步对 StreamGraph 进行转换,得到另一个执行计划图,即 JobGr
https://blog.jrwang.me/2019/flink-source-code-jobgraph/
对于每一个 StreamOperator, 也就是 StreamGraph 中的每一个 StreamGraph,应该是StreamNode?
Flink 源码阅读笔记(2)- JobGraph 的生成 - JR's Blog
前面的文章我们介绍了 StreamGraph 的生成,这个实际上只对应 Flink 作业在逻辑上的执行计划图。Flink 会进一步对 StreamGraph 进行转换,得到另一个执行计划图,即 JobGr
https://blog.jrwang.me/2019/flink-source-code-jobgraph/