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