一、概述
其针对数据流的分布式计算提供了数据分布,数据通信及容错机制等功能。
Flink 官网:
不同版本的文档:
flink on k8s 官方文档:
GitHub 地址:
二、Flink 运行模式
官方文档:
https://nightlies.apache.org/flink/flink-docs-release-1.17/zh/docs/deployment/overview/
Flink on yarn 有三种运行模式:
- yarn-session 模式(Seesion Mode)
- yarn-cluster 模式(Per-Job Mode)
- Application 模式(Application Mode)
- 【温馨提示】Per-Job 模式(已弃用),Per-job 模式仅由 YARN 支持,并已在 Flink 1.15 中弃用。它将被丢弃在 FLINK-26000 中。
三、Flink on k8s 实战操作
1)flink 下载
下载地址:
wget https://dlcdn.apache.org/flink/flink-1.14.6/flink-1.14.6-bin-scala_2.12.tgz