跳到主要内容

Flink安装部署

00-安装包下载

使用flink官网下载速度较慢,可以使用国内镜像网站:一些国内的镜像网站可能会提供Flink安装包的镜像下载,速度可能会比官网快。您可以在搜索引擎中搜索"Flink 1.17 镜像下载"来查找相关的镜像网站。

下载下来的文件:flink-1.17.0-bin-scala_2.12.tgz

01-下载flink安装包上传到服务器,进行解压

把下载的文件传到服务器上:例如:/opt/flinkzip/文件下,然后进行解压,例如解压到/rkhome/目录下

tar -zxvf flink-1.17.0-bin-scala_2.12.tgz -C /rkhome/

02-修改配置文件

进入/rkhome/flink-1.17.0/conf目录,找到flink-conf.yaml文件,修改如下信息

#任务插槽数 taskmanager.numberOfTaskSlots: 16 #设置外部链接可以访问 rest.bind-address: 0.0.0.0 #修改访问端口 rest.port: 8082 --默认8081端口

#以下为增加flink任务启动时,临时文件存储路径

指定临时目录

taskmanager.tmp.dirs: /your_path(存储路径)/temp/dir

03-修改环境变量

执行启动命令,修改环境变量

nano /etc/profile

添加如下信息:

export FLINK_HOME=/rkhome/flink-1.17.0 export PATH=$FLINK_HOME/bin:$PATH 添加完成之后Ctrl+O保存,回车键,Ctrl+X退出,执行命令应用修改后的环境变量

source /etc/profile

04-启动和停止项目

进入到安装目录/rkhome/flink-1.17.0/bin/

执行命令 start-cluster.sh --启动 stop-cluster.sh --停止 查看是否启动成功

ps -ef | grep flink

05-访问flink应用

1.浏览器地址栏输入

ip:8081 --默认端口8081

2.如果访问失败,检查防火墙和端口是否开启

查看防火墙是否开启了8081端口: firewall-cmd --permanent --query-port=8081/tcp 如果结果为no,表示端口没有开启,那么可以开启端口:

firewall-cmd --permanent --add-port=8081/tcp 如果成功开启,会打印success。接下来需要重新加载防火墙策略:

firewall-cmd --reload 如果重新加载成功,会打印success。最后再次查看8081端口开启状态:

firewall-cmd --permanent --query-port=8081/tcp 如果看到结果为yes,表示8081端口开启成功。再次访问即可