我正在尝试在hadoop中添加一个新的调度程序。它不是默认的（fairscheduler/capacityscheduler）。我和svn核实了消息来源。现在，我应该编辑哪个源文件/类来获得这个功能？
k75qkfdt1#
你应该延长上课时间 TaskScheduler 为了编写自己的调度程序。完成后，可以通过jobtracker属性将其插入到代码中 mapred.jobtracker.taskScheduler . 你可以在里面找到taskscheduler org.apache.hadoop.mapred .hth公司
TaskScheduler
mapred.jobtracker.taskScheduler
org.apache.hadoop.mapred
1条答案
按热度按时间k75qkfdt1#
你应该延长上课时间
TaskScheduler为了编写自己的调度程序。完成后，可以通过jobtracker属性将其插入到代码中mapred.jobtracker.taskScheduler. 你可以在里面找到taskschedulerorg.apache.hadoop.mapred.hth公司