java - MapReduce 新 API Job.getInstance(Configuration, String) 的 Jar 文件

Question

已安装 Hadoop 2.2。尝试删除已弃用的 API

    Job job = new Job(conf, "word count");

来自 Wordcount 示例(Hadoop 附带)here

将已弃用的 API 替换为

编辑:

    Job job = Job.getInstance(conf, "word count");

编译错误为

Job.getInstance cannot be resolved to a type.

已经导入的 Job 类(旧 API 或 MR1)似乎没有此方法。

哪个 jar 包含带有 Job.getInstance(Configuratio,String) 方法的新 Job 类

如何解决？迁移到 MapReduce v2 的示例是否有任何其他更改？

Answer 1

我解决这个问题的方法是添加 hadoop-core作为依赖。我只指定了 hadoop-common .

<dependency>
    <groupId>org.apache.hadoop</groupId>
    <artifactId>hadoop-core</artifactId>
    <version>1.2.1</version>
</dependency>
<dependency>
    <groupId>org.apache.hadoop</groupId>
    <artifactId>hadoop-common</artifactId>
    <version>2.7.2</version>
</dependency>