为每个映射任务生成一个输入文件

Question

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

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

在编译时，fs.create行出现错误。有人知道哪里出了问题以及如何解决吗？感谢

Answer 1

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