You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by dd...@apache.org on 2008/10/16 07:56:17 UTC
svn commit: r705145 - in /hadoop/core/trunk: CHANGES.txt
src/contrib/capacity-scheduler/src/test/org/apache/hadoop/mapred/TestCapacityScheduler.java
Author: ddas
Date: Wed Oct 15 22:56:16 2008
New Revision: 705145
URL: http://svn.apache.org/viewvc?rev=705145&view=rev
Log:
HADOOP-4426. TestCapacityScheduler broke due to the two commits HADOOP-4053 and HADOOP-4373. This patch fixes that. Contributed by Hemanth Yamijala.
Modified:
hadoop/core/trunk/CHANGES.txt
hadoop/core/trunk/src/contrib/capacity-scheduler/src/test/org/apache/hadoop/mapred/TestCapacityScheduler.java
Modified: hadoop/core/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/CHANGES.txt?rev=705145&r1=705144&r2=705145&view=diff
==============================================================================
--- hadoop/core/trunk/CHANGES.txt (original)
+++ hadoop/core/trunk/CHANGES.txt Wed Oct 15 22:56:16 2008
@@ -934,6 +934,9 @@
HADOOP-4335. Fix FsShell -ls for filesystems without owners/groups. (David
Phillips via cdouglas)
+ HADOOP-4426. TestCapacityScheduler broke due to the two commits HADOOP-4053
+ and HADOOP-4373. This patch fixes that. (Hemanth Yamijala via ddas)
+
Release 0.18.2 - Unreleased
BUG FIXES
Modified: hadoop/core/trunk/src/contrib/capacity-scheduler/src/test/org/apache/hadoop/mapred/TestCapacityScheduler.java
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/capacity-scheduler/src/test/org/apache/hadoop/mapred/TestCapacityScheduler.java?rev=705145&r1=705144&r2=705145&view=diff
==============================================================================
--- hadoop/core/trunk/src/contrib/capacity-scheduler/src/test/org/apache/hadoop/mapred/TestCapacityScheduler.java (original)
+++ hadoop/core/trunk/src/contrib/capacity-scheduler/src/test/org/apache/hadoop/mapred/TestCapacityScheduler.java Wed Oct 15 22:56:16 2008
@@ -471,7 +471,7 @@
taskTrackerManager.addQueues(new String[] {"default"});
resConf = new FakeResourceManagerConf();
ArrayList<FakeQueueInfo> queues = new ArrayList<FakeQueueInfo>();
- queues.add(new FakeQueueInfo("default", 1f, 1, true, 1));
+ queues.add(new FakeQueueInfo("default", 100.0f, 1, true, 1));
resConf.setFakeQueues(queues);
scheduler.setResourceManagerConf(resConf);
scheduler.start();
@@ -681,10 +681,10 @@
scheduler.start();
// submit a job to the default queue
- submitJob(JobStatus.PREP, 10, 0, "default", "u1");
+ submitJobAndInit(JobStatus.PREP, 10, 0, "default", "u1");
// submit a job to the second queue
- submitJob(JobStatus.PREP, 10, 0, "q2", "u1");
+ submitJobAndInit(JobStatus.PREP, 10, 0, "q2", "u1");
// job from q2 runs first because it has some non-zero capacity.
checkAssignment("tt1", "attempt_test_0002_m_000001_0 on tt1");