java - 为每个 map task 生成一个输入文件

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 和 create 中抛出的close。