2015-07-21 35 views

回答

2

conf.set("mapreduce.job.end-notification.url","url")

會做。 url應該是http url,您將收到回調。

從的javadoc:

設置URI來按順序發送通知作業完成(成功/失敗)之後被調用。

uri可以包含2個特殊參數:$ jobId和$ jobStatus。那些如果存在的話,分別被作業的標識符和完成狀態所取代。

這通常由應用程序編寫者用異步方式實現Map-Reduce作業的鏈接。

請注意,較舊的hadoop版本使用job.end.notification.url
它在較新的版本中被棄用,有利於mapreduce.job.end-notification.url

參考mapred-default.xml#mapreduce.job.end-notification.url