Python hadoop流:设置作业名称

Question

• 我有一个使用hadoop流在集群上运行的作业
• 我必须启动一个新作业，我想为其添加作业名称，如何在命令行或文件上传递该选项以设置作业名称
• 在Java中，您可以说

JobConf conf = new JobConf(WordCount.class);
conf.setJobName("wordcount");

如何使用hadoop流媒体实现这一点？

Answer 1

使用-D key=value表示法配置属性：

-D mapred.job.name='My Job'

您可以通过仅使用-info参数