我正在hadoop中实现一个新的调度算法,名为 TaskTrackerAware Scheduler . 我必须配置一些属性,如mapred.tascheduler.task.max(单个作业可以在tasktracker上运行的最大任务数)和mapred.tascheduler.hosts(需要在其中运行作业的任务跟踪器的主机名)。如何在作业配置对象中配置这些属性?
TaskTrackerAware Scheduler
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");
如果你需要进一步的帮助,请告诉我。。
1条答案
按热度按时间e3bfsja21#
在下面的片段中找到可能对您有所帮助的内容,
如果你需要进一步的帮助,请告诉我。。