继前文 Flink 原理与实现:架构和拓扑概览中介绍了 Flink 的四层执行图模型,本文将主要介绍 Flink 是如何将 StreamGraph 转换成 JobGraph 的。根据用户用 Stream API 编写的程序,构造出一个代表拓扑结构的 StreamGraph 的。以 Wor...
Continue reading继前文 Flink 原理与实现:架构和拓扑概览中介绍了 Flink 的四层执行图模型,本文将主要介绍 Flink 是如何将 StreamGraph 转换成 JobGraph 的。根据用户用 Stream API 编写的程序,构造出一个代表拓扑结构的 StreamGraph 的。以 Wor...
Continue reading