从java应用程序在hadoop2.2(Yarn)上启动mapreduce作业



我正试图从java应用程序调用mapreduce作业。在以前的hadoop版本(1.x)中,我创建了一个Configuration对象和一个Job对象,在Configuration中设置mapred.Job.trackerfs.default.name并运行Job。现在,在hadoop2.x中,作业跟踪器已经不存在了,也不存在任何关于如何编程运行MR1作业的文档。有什么想法吗?

我要找的是这里给出的解释:从一个简单的java程序

调用mapreduce作业

MR客户端API与传统MR和YARN相同。可以在Configuration对象上设置属性,而不是在xml配置文件中指定。请在此处和此处查看文档和所需配置,以在YARN中设置和执行简单的MR作业。

相关内容

  • 没有找到相关文章

最新更新