在统信UOS系统上部署Flink需先确认Java环境为JDK 11或17,再下载解压Flink二进制包,配置FLINK_HOME与PATH环境变量,修改flink-conf.yaml中jobmanager.rpc.address为0.0.0.0并调高taskmanager.slot数,最后执行start-cluster.sh启动集群并通过localhost:8081验证。

在统信UOS系统上部署Flink用于流式数据处理,需先确认Java环境可用,再下载适配Linux的Flink二进制包,完成解压、环境变量配置与核心参数调整后启动集群服务。
确认Java运行环境
打开终端,执行 java -version。若返回 JDK 11 或 JDK 17 的版本信息(如 openjdk version "17.0.1"),说明环境就绪。若提示 command not found 或版本低于11,请先通过应用商店搜索“JDK”安装官方适配的OpenJDK包。
【必须使用JDK 11或17】 Flink 1.15+ 版本不再兼容 JDK 8,强行使用会导致 JobManager 启动失败且无明确报错。
下载并解压Flink安装包
访问 Apache Flink 官网下载页面,选择最新稳定版(如 flink-1.19.1-bin-scala_2.12.tgz),下载到“下载”目录。
在终端中执行以下命令解压至 /opt 目录:
sudo tar -xzf ~/下载/flink-*.tgz -C /opt
解压后进入目录:cd /opt/flink-*。注意:目录名含版本号,用 Tab 键自动补全最稳妥。
配置Flink环境变量
编辑当前用户环境文件:vim ~/.bashrc,在末尾添加两行:
export FLINK_HOME=/opt/flink-1.19.1export PATH=$PATH:$FLINK_HOME/bin
保存退出后立即生效:source ~/.bashrc。验证是否成功:echo $FLINK_HOME 应输出路径,flink --version 应显示版本号。
修改核心配置文件
进入配置目录:cd $FLINK_HOME/conf。
编辑 flink-conf.yaml:
将 jobmanager.rpc.address: localhost 改为 jobmanager.rpc.address: 0.0.0.0 ——否则 Web UI 只能本机访问,远程浏览器打不开 8081 端口。
将 taskmanager.numberOfTaskSlots: 1 改为 taskmanager.numberOfTaskSlots: 4,提升本地并发能力。
保存文件。这一步不改,集群虽能启动,但 Web UI 无法从其他设备访问,调试和监控功能形同虚设。
启动Flink单机集群
执行启动脚本:$FLINK_HOME/bin/start-cluster.sh。
检查进程是否运行:jps | grep -E "(StandaloneSession|TaskManager)"。应看到 StandaloneSessionClusterEntrypoint 和 TaskManagerRunner 两个进程。
打开浏览器,访问 http://localhost:8081。页面加载成功即表示部署完成。

















