我知道org.apache.hadoop.mapred.JobConf.setJobEndNotificationURI
可以向hadoop作业注册一个回调url,该回调url可以在作业完成后调用,但是在新的mapreduce api中(我的意思是 org.apache.hadoop.mapreduce 包),org.apache.hadoop.mapreduce.Job 不包含此类 API。
新的 MapReduce API 中 setJobEndNotificationURI
的等效项是什么?
最佳答案
您可以将 -Djob.end.notification.url
作为参数传递给您的作业。否则,
job.getConfiguration().set("job.end.notification.url","http url")
应该做得很好。
关于java - 如何在新的mapreduce API中设置JobEndNotificationURI?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/18617609/