单机版部署
下载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