这篇文章主要介绍Linux系统如何安装Flink,文中介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们一定要看完!
Flink是用Java和Scala编写一个开源流处理框架,Flink以数据并行和流水线方式执行任意流数据程序,Flink的流水线运行时系统可以执行批处理和流处理程序。
下载
flink有两个版本,一个版本是和hadoop捆绑的,另一个是单独的,我们以单独的为例:
flink-1.9.3-bin-scala_2.11.tgz
解压
tar -zxvf flink-1.9.3-bin-scala_2.11.tgz -C /opt/
解压到/opt/目录下
配置环境变量
打开配置文件:
vi /etc/profile
配置内容如下:
# Flink
export FLINK_HOME=/opt/flink-1.9.3
export PATH=$FLINK_HOME/bin:$PATH
保存配置:
source /etc/profile
启动Flink
执行
start-cluster.sh
jps查看是否启动成功:
查看管理页面
http://ip地址:8081
运行一个example
(1)打开第一个窗口:
监听8888端口:
nc -lk 8888
如果没有安装nc,执行如下命令安装:
yum install -y nc
(2)打开第二个窗口
进入flink安装目录,启动单词统计的java程序 SocketWindowWordCount,并监听8888端口
flink run examples/streaming/SocketWindowWordCount.jar –port 8888
(3)打开第三个窗口
进入flink安装目录下的log目录,查看统计结果:
tail -f flink-root-taskexecutor-0-bigdata111.out
以上是“Linux系统如何安装Flink”这篇文章的所有内容,感谢各位的阅读!希望分享的内容对大家有帮助,更多相关知识,欢迎关注编程网行业资讯频道!