Apache Flink 进阶(四):Flink on Yarn/K8s 原理剖析及实践

  1. 云栖社区>
  2. 阿里云实时计算>
  3. 博客>
  4. 正文

Apache Flink 进阶(四):Flink on Yarn/K8s 原理剖析及实践

ApacheFlink 2019-10-14 20:32:06 浏览2357
展开阅读全文
  • 作者:周凯波(宝牛)
  • 整理:毛鹤

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

Flink 架构概览

Flink 架构概览–Job

img1

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

网友评论

登录后评论
0/500
评论
ApacheFlink
+ 关注
所属团队号: 阿里云实时计算