我知道org.apache.hadoop.mapred.JobConf.setJobEndNotificationURI
可以向hadoop作业注册回调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")
应该做好事。