Changes between Version 10 and Version 11 of schedule

Timestamp:

10/18/2012 03:20:09 PM (14 years ago)

Author:

liaojiaohe

Comment:

--

schedule

@@ -5 +5 @@
 设想方案[[BR]]
 
-*研究Capacity Scheduler 参数[[BR]]
+* 研究Capacity Scheduler 参数[[BR]]
 
-*如果Capacity Scheduler 不能慢速，修改代码让系统把job分配到不同的queue[[BR]]
+* 如果Capacity Scheduler 不能慢速，修改代码让系统把job分配到不同的queue[[BR]]
 
+假设又两条queue:default,highPrior,当default被占满后，而highPrior比较空闲[[BR]]
+ 优先级是HIGH的会被分配到highPrior队列[[BR]]
+
+修改JobQueueManager，jobAdded 函数
+
+
+{{{
+  @Override
+  public void jobAdded(JobInProgress job) throws IOException {
+    LOG.info("Job " + job.getJobID() + " submitted to queue " + 
+        job.getProfile().getQueueName());
+    
+    // add job to the right queue
+    CapacitySchedulerQueue queue = getQueue(job.getProfile().getQueueName());
+    if (null == queue) {
+      // job was submitted to a queue we're not aware of
+      LOG.warn("Invalid queue " + job.getProfile().getQueueName() + 
+          " specified for job" + job.getProfile().getJobID() + 
+          ". Ignoring job.");
+      return;
+    }
+    // add job to waiting queue. It will end up in the right place, 
+    // based on priority. 
+    queue.addWaitingJob(job);
+    // let scheduler know. 
+    scheduler.jobAdded(job);
+  }
+}}}