前置环境配置jdk可以参考博文:Centos7下安装hadoop单节点 。
如下图所示,这里我们将flink-1.13.0-bin-scala_2.12.tgz上传到如下路径:
解压安装文件到/opt/module下面
tar -zxvf flink-1.13.0-bin-scala_2.12.tgz -C /opt/module/
将flink添加到环境变量,获取flink安装路径
[root@centos3 flink-1.13.0]# pwd
/opt/module/flink-1.13.0
打开/etc/profile.d/my_env.sh文件
vim /etc/profile.d/my_env.sh
在my_env.sh文件末尾添加如下内容:
export FLINK_HOME=/opt/module/flink-1.13.0
export PATH=$FLINK_HOME/bin:$PATH
保存并退出: :wq
,让修改后的文件生效
source /etc/profile
测试是否安装成功
[root@centos3 flink-1.13.0]# flink --version
Version: 1.13.0, Commit ID: f06faf1
使用如下命令启动Flink:
./bin/start-cluster.sh
[root@centos3 flink-1.13.0]# ./bin/start-cluster.sh
Starting cluster.
Starting standalonesession daemon on host centos3.
使用jps命令检测:
[root@centos3 flink-1.13.0]# jps
9072 StandaloneSessionClusterEntrypoint
9442 Jps
9337 TaskManagerRunner
浏览器访问 :http://192.168.255.130:8081/ ,这里IP是虚拟机的IP。
Flink安装包中自带了测试样例,这里可以运行WordCount样例程序来测试Flink的运行效果,具体命令如下:
flink run /opt/module/flink-1.13.0/examples/batch/WordCount.jar