2

複数のステップを持つジョブを含む、Python ライブラリmrjobから開始されたいくつかの異なるジョブがあります。streamjobカスタム名に置き換えるにはどうすればよいですか? たとえばwordcount_step_1、wordcount_step_2、 などです。

Hadoop 管理のスクリーンショット

4

2 に答える 2

5

もちろん、ジョブを実行するときに--jobconfオプションを使用して指定するだけです。

例えば：

if __name__ == '__main__':
    # Be careful, this appends all job args, if you have lots it could be a problem
    sys.argv.extend(["--jobconf", "mapred.job.name=%s" % " ".join(sys.argv)])
    MRYourJobClass.run()
于 2014-01-10T06:01:25.170 に答える
0

ジョブを実行するときに、次のオプションを追加します。

--jobconf mapred.job.name=NameOfTheJob
于 2016-09-13T15:17:15.117 に答える