Hadoop Job Manipulation

向 Hadoop 群集中提交的 Job 在有害环境中可能被篡改。

Hadoop job manipulation 错误在以下情况中出现：

- 数据从一个不可信赖的数据源进入程序。

- 数据用来指定控制客户端作业的 JobConf 值。

Hadoop 群集是一种有害环境。当用来防止对群集设备中 HDFS 未经授权访问的安全配置设置不当时，攻击可能会乘机进行控制。从而造成 Hadoop 群集提供的任何数据被篡改的可能性。

例 1：下列代码是典型客户端应用程序中提交的 Job，其输入来自 Hadoop 群集中主计算机的命令行：

  public void run(String args[]) throws IOException {

    String inputDir = args[0];
    String outputDir = args[1];

    // Untrusted command line argument
    int numOfReducers = Integer.parseInt(args[3]);
    Class mapper = getClassByName(args[4]);
    Class reducer = getClassByName(args[5]);

    Configuration defaults = new Configuration();
    JobConf job = new JobConf(defaults, OptimizedDataJoinJob.class);
    job.setNumMapTasks(1);
    // An attacker may set random values that exceed the range of acceptable number of reducers
    job.setNumReduceTasks(numOfReducers);

    return job;
  }

例 2：以下代码显示了攻击者通过命令行参数控制运行作业中止的情形：

  public static void main(String[] args) throws Exception {

    JobID id = JobID.forName(args[0]);
    JobConf conf = new JobConf(WordCount.class);
    // configure this JobConf instance
    ...
    JobClient.runJob(conf);
    RunningJob job = JobClient.getJob(id);
    job.killJob();

  }