操作系统:centos7
JDK版本:JDK1.8 ,JAVA安装教程见:http://www.saoniuhuo.com/article/detail-92.html
方式一:官网下载。
官网下载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目录下.
$ cd /root/soft
$ sudo tar -zxf flink-1.9.2-bin-scala_2.11.tgz
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已经正常启动
内容来源于网络,如有侵权,请联系作者删除!