爲每個地圖任務生成輸入文件

Question

我是新來的hadoop，我有以下問題。我想控制mappers的數量，而我發現的最簡單的方法就是欺騙hadoop爲每個map任務生成一個輸入文件，就像在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

你應該趕上（或重投）IOException可能從create和close拋出。