Apache Flink 是一个在有界数据流和无界数据流上进行有状态计算分布式处理引擎和框架。专为处理大规模数据流而设计，它能够在低延迟和高吞吐的场景下高效地处理实时和批量数据。

目录

环境要求：

• JDK11

• Flink版本为1.20.2

• 官方文档：https://nightlies.apache.org/flink/flink-docs-release-1.20/zh/

• 安装包下载地址：https://www.apache.org/dyn/closer.lua/flink/flink-1.20.2/flink-1.20.2-bin-scala_2.12.tgz

集群节点

节点	node1	node2	node3
角色	JobManager、TaskManager	TaskManager	TaskManager

并配置每台节点间的免密操作。

安装与配置

解压安装包

tar -zxvf flink-1.20.2-bin-scala_2.12.tgz

修改集群配置

主节点修改

修改config.yaml以下内容为对应配置：

vim config.yaml

jobmanager:
  bind-host: 0.0.0.0
  rpc:
    address: node1
taskmanager:
  bind-host: 0.0.0.0
  host: node1
rest:
  address: node1
  bind-address: 0.0.0.0

修改workers内容为对应的集群配置：

node1
node2
node3

修改masters配置：

node1:8081

其他节点

分发已修改好配置的包：

scp -r flink node2:/
scp -r flink node3:/

修改对应节点配置：

vim config.yaml

--node2
taskmanager.host: node2
--node3
taskmanager.host: node3

启动集群

在主节点node1上执行命令：

# 启动集群
bin/start-cluster.sh

# 停止集群
bin/stop-cluster.sh

WebUI控制台

访问node1:8081