单机版部署
下载flink的包:https://archive.apache.org/dist/flink/flink-1.10.1/flink-1.10.1-bin-scala_2.12.tgz
我这里把包放到/opt下面了,解压:
cd /opt
tar -xvf flink-1.10.1-bin-scala_2.12.tgz
./bin/start-cluster.sh


启动成功后,就可以进入web dashboard了(8081端口):http://192.168.1.40:8081/

Task Managers信息:

提交job运行
将上一节中的代码打成jar包:https://www.cnblogs.com/wwjj4811/p/15211936.html
上传:


显示执行计划:

退出,点击submit

但是我们发现任务并不能执行成功。
这是因为我分配的Task Slots不够。
重新配置flink后,重新启动
vi conf/flink-conf.yaml
#这里给当前机器的cpu个数
taskmanager.numberOfTaskSlots: 8

重新提交刚才的任务并执行,执行nc -lk 7777,发现flink可以收到输入内容

标准输出内容:


命令行提交job
-p表示三个并行度。
./bin/flink run -c com.wj.wc.StreamWordCount -p 3 /root/flink-demo-1.0-SNAPSHOT.jar --host 192.168.1.40 --port 7777

在running jobs这里就能看到刚才提交的job

命令行取消job
查看正在运行的job:
./bin/flink list

取消job:
./bin/flink cancel jobId
