diff --git a/hadoop-mapreduce-project/CHANGES.txt b/hadoop-mapreduce-project/CHANGES.txt index 32df54de87..ca1e4483b2 100644 --- a/hadoop-mapreduce-project/CHANGES.txt +++ b/hadoop-mapreduce-project/CHANGES.txt @@ -207,6 +207,8 @@ Release 2.3.0 - UNRELEASED created by CombineFileInputFormat to fail (Robert Parker and Jason Lowe via jlowe) + MAPREDUCE-5610. TestSleepJob fails in jdk7 (Jonathan Eagles via jlowe) + Release 2.2.1 - UNRELEASED INCOMPATIBLE CHANGES diff --git a/hadoop-tools/hadoop-gridmix/src/main/java/org/apache/hadoop/mapred/gridmix/JobCreator.java b/hadoop-tools/hadoop-gridmix/src/main/java/org/apache/hadoop/mapred/gridmix/JobCreator.java index f31e854ac0..c109e3fa3e 100644 --- a/hadoop-tools/hadoop-gridmix/src/main/java/org/apache/hadoop/mapred/gridmix/JobCreator.java +++ b/hadoop-tools/hadoop-gridmix/src/main/java/org/apache/hadoop/mapred/gridmix/JobCreator.java @@ -63,8 +63,8 @@ public GridmixJob createGridmixJob( Configuration conf, long submissionMillis, JobStory jobdesc, Path outRoot, UserGroupInformation ugi, int seq) throws IOException { int numLocations = conf.getInt(SLEEPJOB_RANDOM_LOCATIONS, 0); - if (numLocations < 0) numLocations=0; - if ((numLocations > 0) && (hosts == null)) { + if (numLocations < 0) numLocations = 0; + if (hosts == null) { final JobClient client = new JobClient(new JobConf(conf)); ClusterStatus stat = client.getClusterStatus(true); final int nTrackers = stat.getTaskTrackers(); diff --git a/hadoop-tools/hadoop-gridmix/src/test/java/org/apache/hadoop/mapred/gridmix/TestSleepJob.java b/hadoop-tools/hadoop-gridmix/src/test/java/org/apache/hadoop/mapred/gridmix/TestSleepJob.java index 8f58e9d66d..580910cb4c 100644 --- a/hadoop-tools/hadoop-gridmix/src/test/java/org/apache/hadoop/mapred/gridmix/TestSleepJob.java +++ b/hadoop-tools/hadoop-gridmix/src/test/java/org/apache/hadoop/mapred/gridmix/TestSleepJob.java @@ -58,17 +58,6 @@ public static void shutDown() throws IOException { } - /* - * test RandomLocation - */ - @Test - public void testRandomLocation() throws Exception { - UserGroupInformation ugi = UserGroupInformation.getLoginUser(); - - testRandomLocation(1, 10, ugi); - testRandomLocation(2, 10, ugi); - } - @Test public void testMapTasksOnlySleepJobs() throws Exception { Configuration configuration = GridmixTestUtils.mrvl.getConfig(); @@ -90,6 +79,17 @@ public void testMapTasksOnlySleepJobs() throws Exception { assertEquals(6, seq); } + /* + * test RandomLocation + */ + @Test + public void testRandomLocation() throws Exception { + UserGroupInformation ugi = UserGroupInformation.getLoginUser(); + + testRandomLocation(1, 10, ugi); + testRandomLocation(2, 10, ugi); + } + // test Serial submit @Test public void testSerialSubmit() throws Exception {