| Version 7 (modified by liaojiaohe, 14 years ago) (diff) |
|---|
功能目标:
读取任务运行时间等信息,为任务调配作数据基础
任务设置优先级,根据优先级调配任务
时间触发任务
WEB界面上实现取消任务功能
一些可能用到的参数
mapreduce.job.complete.cancel.delegation.tokens
job.end.notification.url
有几个东西有待确认:
- 提交后的任务(pending状态)参数是否还可以修改,比如优先级,reduce的数量
是否可以通过API拿Hadoop的信息,可以通过下面的代码
Configuration conf = new Configuration();
String[] otherArgs = new GenericOptionsParser(conf, args).getRemainingArgs();
JobClient jobClient = new JobClient(new JobConf(conf));
JobQueueInfo[] queues = jobClient.getQueues();
Attachments
-
src.zip
(38.5 KB) -
added by liaojiaohe 13 years ago.
-
hadoop-capacity-scheduler-1.0.3.jar
(63.9 KB) -
added by liaojiaohe 13 years ago.
![(please configure the [header_logo] section in trac.ini)](http://www1.pconline.com.cn/hr/2009/global/images/logo.gif)