Flink StreamGraph 到 JobGraph 转换:发生在哪里?
Flink 的 StreamGraph 在客户端被转换为 JobGraph。具体而言,当在客户端(例如,运行 Flink 应用程序的机器上的命令行界面或 Web 界面)创建 StreamExecutionEnvironment 时,会创建 StreamGraph。然后,通过将 StreamGraph 提交给 JobManager 来执行转换为 JobGraph。因此,StreamGraph 的转换发生在客户端和 JobManager 之间的交互过程中。
原文地址: https://www.cveoy.top/t/topic/jKWO 著作权归作者所有。请勿转载和采集!