1. 下载安装

官网下载:https://flink.apache.org/zh/downloads/

wget https://dlcdn.apache.org/flink/flink-1.16.2/flink-1.16.2-bin-scala_2.12.tgz --no-check-certificate
tar -zxvf flink-1.16.2-bin-scala_2.12.tgz

2. 配置

添加子节点

vim conf/workers
node2
node3

启动

bin/start-cluster.sh
bin/stop-cluster.sh

分发

cd ../
scp -r flink-1.16.2/ node2:$PWD

运行示例

bin/flink run examples/streaming/WordCount.jar