1.下載二進制的Flink,根據你喜歡的Hadoop/Scala版本選擇對應的Flink版本。
https://flink.apache.org/downloads.html
2.選擇存放目錄 解壓 flink-1.7.2-bin-hadoop28-scala_2.11.tar
存放目錄: /usr/local/flink
解壓: tar -xvf flink-1.7.2-bin-hadoop28-scala_2.11.tar
3.配置flink環境變量
4.啟動Flink
./bin/start-local.sh
5.停止Flink
./bin/stop-local.sh
6.下載nc本地監聽
yum -y install nc
查看進程
ps -ef|grep flink
或
jps
netstat -anlp | grep 9000
運行jar：
./bin/flink run examples/streaming/SocketWindowWordCount.jar --port 9000
不同方式
./bin/flink run -c com.yw.rabbitmqConsumer rabbitmqConsumer-1.0-SNAPSHOT.jar
查看日志
tail -f flink-root-*.out