一、概述

其针对数据流的分布式计算提供了数据分布,数据通信及容错机制等功能。

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