这篇文章主要为大家展示了“Linux系统中如何安装Flink”，内容简而易懂，条理清晰，希望能够帮助大家解决疑惑，下面让小编带领大家一起研究并学习一下“Linux系统中如何安装Flink”这篇文章吧。
在当前的互联网用户，设备，服务等激增的时代下，其产生的数据量已不可同日而语了。各种业务场景都会有着大量的数据产生，如何对这些数据进行有效地处理是很多企业需要考虑的问题。以往我们所熟知的Map Reduce，Storm，Spark等框架可能在某些场景下已经没法完全地满足用户的需求，或者是实现需求所付出的代价，无论是代码量或者架构的复杂程度可能都没法满足预期的需求。新场景的出现催产出新的技术，Flink即为实时流的处理提供了新的选择。Apache Flink就是近些年来在社区中比较活跃的分布式处理框架，加上阿里在中国的推广，相信它在未来的竞争中会更具优势。 Flink的产生背景不过多介绍，感兴趣的可以Google一下。Flink相对简单的编程模型加上其高吞吐、低延迟、高性能以及支持exactly-once语义的特性，让它在工业生产中较为出众。相信正如很多博客资料等写的那样”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”这篇文章的所有内容，感谢各位的阅读！相信大家都有了一定的了解，希望分享的内容对大家有所帮助，如果还想学习更多知识，欢迎关注亿速云行业资讯频道！
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
