0

我正在尝试在 Hadoop 中添加一个新的调度程序。它不是默认的（FairScheduler/CapacityScheduler）。我用svn检查了源代码。现在，我应该编辑哪个源文件/类来获得这个功能？

4

1 回答 1

1

您应该扩展该类TaskScheduler以编写自己的调度程序。完成后，您可以通过 JobTracker 属性将其插入您的代码中mapred.jobtracker.taskScheduler。你可以在里面找到TaskScheduler org.apache.hadoop.mapred。

高温高压

于 2013-06-15T19:31:40.910 回答