java - 如何在新的 mapreduce API 中设置JobEndNotificationURI？

Question

我知道org.apache.hadoop.mapred.JobConf.setJobEndNotificationURI可以将回调 url 注册到可以在作业完成后调用的 hadoop 作业，但是在新的 mapreduce api（我的意思是org.apache.hadoop.mapreduce包）中，org.apache.hadoop.mapreduce.Job不包含此类 API。

setJobEndNotificationURI新的 mapreduce API 中的等价物是什么？

Answer 1

您可以将-Djob.end.notification.url作为参数传递给您的工作。别的，

job.getConfiguration().set("job.end.notification.url","http url") 

应该做得很好。