前置环境配置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

推荐阅读

评论可见,请评论后查看内容,谢谢!!!
 您阅读本篇文章共花了: