Apache Flink 进阶（四）：Flink on Yarn/K8s 原理剖析及实践

• 作者：周凯波（宝牛）
• 整理：毛鹤

本文主要介绍 F on Yarn/K8s 的原理及应用实践，文章将从 F 架构、F on Yarn 原理及实践、F on Kubernetes 原理剖析三部分内容进行分享并对 F on Yarn/Kubernetes 中存在的部分问题进行了解答。

F 架构概览

F 架构概览–Job

用户通过 DataStream API、DataSet API、SQL 和 Table API 编写 F 任务，它会生成一个JobGraph。JobGraph 是由 source、map()、keyBy()/window()/apply() 和 Sink 等算子组成的。当 JobGraph 提交给 F 集群后，能够以 Local、Standalone、Yar