如何在新的mapreduce API中设置JobEndNotificationURI



我知道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") 

应该做好事。

相关内容

  • 没有找到相关文章

最新更新