本文基于：Flink Java Demo
1.下载
https://dlcdn.apache.org/flink/flink-1.18.0/flink-1.18.0-bin-scala_2.12.tgz
2.解压
mkdir /usr/flink
tar -zxvf /home/flink-1.18.0-bin-scala_2.12.tgz -C /usr/flink/
3.推送端运行netcat
nc -lp 7878
4.将Maven的包复制到flink的lib目录下
cp /home/FlinkTutorial-1.0-SNAPSHOT.jar /usr/flink/flink-1.18.0/lib/
5.启动JobManager
/usr/flink/flink-1.18.0/bin/standalone-job.sh start --job-classname cn.coreqi.WordCountStreamUnboundedDemo
6.启动TaskManager
/usr/flink/flink-1.18.0/bin/taskmanager.sh start
7.停止
/usr/flink/flink-1.18.0/bin/taskmanager.sh stop
/usr/flink/flink-1.18.0/bin/standalone-job.sh stop