CentOS7下的Flink安装及使用

x33g5p2x  于2020-09-03 发布在 Flink  
字(0.7k)|赞(0)|评价(0)|浏览(2817)

1 安装环境

操作系统:centos7
JDK版本:JDK1.8 ,JAVA安装教程见:http://www.saoniuhuo.com/article/detail-92.html

2 Flink软件下载

方式一:官网下载。
官网下载Flink:https://flink.apache.org/downloads.html
方式二:wget获取

wget https://mirrors.bfsu.edu.cn/apache/flink/flink-1.11.1/flink-1.11.1-bin-scala_2.12.tgz

文件保存在/root/soft目录下.

3、安装

$ cd /root/soft
$ sudo tar -zxf flink-1.9.2-bin-scala_2.11.tgz

4、添加环境变量

vim ~/.bashrc
export FLINK_HOME=/opt/software/flink/flink-1.11.1
export PATH=$FLINK_HOME/bin:$PATH

重新进入终端,使环境变量生效。
执行flink命令

$ /root/soft/flink-1.9.2/bin
$ ./start-cluster.sh
$ jps
19489 jar
24595 StandaloneSessionClusterEntrypoint
25189 Jps
25039 TaskManagerRunner

可以通过观察logs目录下的日志来检测系统是否正在运行了

$ tail log/flink-*-standalonesession-*.log

JobManager同时会在8081端口上启动一个web前端,通过 http://localhost:8081 来访问

可以发现flink已经正常启动

相关文章