2012-08-17 72 views

回答

0

我唯一想到的就是擁有一個永久檢查JobA輸出目錄的線程(開始在驅動程序類中)。 當一個(部分)部分r-xxxx文件被創建並完全寫入時,你可以開始JobB作爲特定(一組)部分r-xxxx文件的輸入。

我現在可以識別的唯一問題是與檢查part-r-xxxx文件是否完全寫入有關的唯一問題。

+0

在完全由特定的reducer寫入之前,您不會看到part-r-文件。所以你可以開始處理part-r文件,因爲它們會出現,你會知道它們是完整的。 – 2013-01-08 04:14:36