Flink 环境配置
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