作业配置对象

cgh8pdjw  于 2021-06-02  发布在  Hadoop
关注(0)|答案(1)|浏览(228)

我正在hadoop中实现一个新的调度算法,名为 TaskTrackerAware Scheduler . 我必须配置一些属性,如mapred.tascheduler.task.max(单个作业可以在tasktracker上运行的最大任务数)和mapred.tascheduler.hosts(需要在其中运行作业的任务跟踪器的主机名)。如何在作业配置对象中配置这些属性?

e3bfsja2

e3bfsja21#

在下面的片段中找到可能对您有所帮助的内容,

Configurarion conf = new Configuration();
conf.set("mapred.tascheduler.task.max" , <value>);
conf.set("mapred.tascheduler.hosts " ,   <value>);

Job job = Job.getInstance(conf, "app name");

如果你需要进一步的帮助,请告诉我。。

相关问题