作业配置对象

Question

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

Answer 1

在下面找到可能对您有帮助的代码段，

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

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

如果您需要任何进一步的帮助，请告诉我..

作业配置对象

Job Configuration Object

hadoop

mapreduce