Flink：部署运行

单机版部署

下载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