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参数调用流式jar，就可以列出一大堆选项