java - 为每个地图任务生成一个输入文件

Question

我是hadoop的新手，我有以下问题。我想控制映射器的数量，我发现最简单的方法是欺骗 hadoop 为每个映射任务生成一个输入文件，就像在 pi estimator 示例中一样。所以我使用了以下代码：

    for(int i=0; i < nMaps; ++i) {
    final Path file = new Path(inDir, "part"+i);
    fs.create(file);
    fs.close();
    }

并且在编译时 fs.create 行中有一个错误。有谁知道出了什么问题以及如何解决？谢谢

Answer 1

您应该捕获（或重新抛出）IOException可能从createand抛出的close。