解决问题

centos重启服务出现错误

​ 解决方法：需要 安装iptables-services

--切换到root用户 yum install iptables-services systemctl enable iptables.service //设置开机启动

centos查看端口出错

解决方法：没有 ifconfig 和netstat -an 的话安装 net-tools package

yum install net-tools

centos 7 防火墙指令虽然兼容iptables，但是还是用firewalld

启动Flink后，设置端口为8010，地址用

ip addr

查看，如我VM centos地址为192.168.56.129，则浏览器打开192.168.56.129:8081

centos 7 flink1.7 启动文档

flink监听

在本机

nc -l 9000

复制会话

在文件夹flink-1.7.0下执行以下命令，即可监听本机9000端口，等待该端口的数据：

此时刷新，就会出现一个job

filnk注意事项

需要开启3个会话

第一个会话：连接本机端口 nc -l 9000

第二个会话：在文件夹flink-1.7.0下执行以下命令，即可监听本机9000端口，等待该端口的数据 ./bin/flink run examples/streaming/SocketWindowWordCount.jar --port 9000

​ 此时，在网页刷新，就已经可以看到job

第三个会话：在第一个会话输入单词后，在第三个会话进入log

tail -f flink-操作用户名-taskexecutor-4-主机名.out

不一定是“4”,我是根据.OUT文件大小判定的，启动后，当在第一个会话输入单词，第三个会话就会有新数据产生。

Flink实战：消费Wikipedia实时消息

网址

思路：cmd指令创建maven项目->windows打开->配置POM->编写代码->VM打开Flink->添加new job

效果：