1

Java アプリケーションから mapreduce ジョブを呼び出そうとしています。以前の Hadoop バージョン (1.x) では、構成オブジェクトとジョブ オブジェクトを作成し、構成に mapred.job.tracker と fs.default.name を設定して、ジョブを実行しました。

現在、hadoop 2.x では、ジョブ トラッカーは存在せず、MR ジョブをプログラムで実行する方法に関するドキュメントも存在しません。何か案は?

私が探しているのは、ここにある説明です: call mapreduce from a java program

4

2 に答える 2

3

次の 3 つが必要です。

// this should be like defined in your yarn-site.xml
conf.set("yarn.resourcemanager.address", "yarn-manager.com:50001"); 

// framework is now "yarn", should be defined like this in mapred-site.xm
conf.set("mapreduce.framework.name", "yarn");

// like defined in hdfs-site.xml
conf.set("fs.default.name", "hdfs://namenode.com:9000");

Hadoop 2.2.0 のドキュメントに詳しい説明があります。

于 2014-08-14T19:54:21.717 に答える