Linux安装flink_linux 安装flink

一、下载Flink（2种方式为了简单我用第二种。）

1、手动下载Flink

1.1、官网下载:https://flink.apache.org/downloads.html#apache-flink-172

1.2、下载压缩包 上传服务器自己创建的目录（略）。

2、自动下载Flink

创建目录： mkdir /root/kingyifan/flink
下载Flink: wget mirrors.hust.edu.cn/apache/flink/flink-1.7.2/flink-1.7.2-bin-hadoop24-scala_2.11.tgz（版本号请访问网站自行查询）

具体版本号请查阅：http://mirrors.hust.edu.cn/apache/flink/

二、解压压缩包

命令：tar -zxvf flink-1.7.2-bin-hadoop24-scala_2.11.tgz 

解压成功：

三、启动Flink

进入bin目录：cd /root/kingyifan/flink/flink-1.7.2/bin/
启动flink：./start-cluster.sh

查看是否启动成功：

 命令：jps

三、centos6开放flink默认端口（8081） 修改iptables

进入配置iptables：vi /etc/sysconfig/iptables
增加：-A INPUT -m state --state NEW -m tcp -p tcp --dport 8081 -j ACCEPT

重启防火墙：service iptables restart

四、访问ui界面：192.168.241.134:8081

五、测试 5.1 先xsheel复制三个会话：

打开第一个会话：

启动一个终端（端口随意）：nc -lk 8888 

打开第二个会话：

进入bin目录：cd /root/kingyifan/flink/flink-1.7.2/
命令：bin/flink run examples/streaming/SocketWindowWordCount.jar --port 8888

打开第三个会话：

进入log目录：cd /root/kingyifan/flink/flink-1.7.2/log
命令：tail -f flink-root-taskexecutor-5-localhost.localdomain.out（不一定是这个日志文件）

日志目录：

在第一个会话随便输入内容

看第三个内容：

有没有一个疑惑 后面的1是个什么？

他在几算多少秒内出现了多少次 我们随便输几个1测试一下

发现他已经几算出来了。

我们也可以看一下Running Jobs

终、、

---

以上linux安装以及部署flink。有什么问题可以联系我哈。

鼓励作者写出更好的技术文档，就请我喝一瓶哇哈哈哈哈哈哈哈。。你们的赞助决定我更新的速度哦！

微信：

支付宝：

---

感谢一路支持我的人。。。。。
 
Love me and hold me
QQ:69673804（16年老号）
EMAIL:itw@tom.com
友链交换
如果有兴趣和本博客交换友链的话，请按照下面的格式在评论区进行评论，我会尽快添加上你的链接。

---

网站名称：KingYiFan’S Blog
网站地址：http://blog.cnbuilder.cn
网站描述：年少是你未醒的梦话，风华是燃烬的彼岸花。
网站Logo/头像： [头像地址](https://blog.cnbuilder.cn/upload/2018/7/avatar20180720144536200.jpg)