Return-Path: Delivered-To: apmail-hadoop-core-commits-archive@www.apache.org Received: (qmail 19562 invoked from network); 8 May 2009 12:27:04 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.3) by minotaur.apache.org with SMTP; 8 May 2009 12:27:04 -0000 Received: (qmail 40477 invoked by uid 500); 8 May 2009 12:27:04 -0000 Delivered-To: apmail-hadoop-core-commits-archive@hadoop.apache.org Received: (qmail 40413 invoked by uid 500); 8 May 2009 12:27:03 -0000 Mailing-List: contact core-commits-help@hadoop.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: core-dev@hadoop.apache.org Delivered-To: mailing list core-commits@hadoop.apache.org Received: (qmail 40404 invoked by uid 99); 8 May 2009 12:27:03 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 08 May 2009 12:27:03 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=10.0 tests=ALL_TRUSTED X-Spam-Check-By: apache.org Received: from [140.211.11.4] (HELO eris.apache.org) (140.211.11.4) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 08 May 2009 12:26:48 +0000 Received: by eris.apache.org (Postfix, from userid 65534) id D993023889D5; Fri, 8 May 2009 12:26:26 +0000 (UTC) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r772956 [2/2] - in /hadoop/core/trunk: ./ src/contrib/ src/contrib/hdfsproxy/ src/test/core/ src/test/core/org/ src/test/core/org/apache/ src/test/core/org/apache/hadoop/ src/test/core/org/apache/hadoop/cli/ src/test/core/org/apache/hadoop/... Date: Fri, 08 May 2009 12:26:26 -0000 To: core-commits@hadoop.apache.org From: ddas@apache.org X-Mailer: svnmailer-1.0.8 Message-Id: <20090508122626.D993023889D5@eris.apache.org> X-Virus-Checked: Checked by ClamAV on apache.org Modified: hadoop/core/trunk/build.xml URL: http://svn.apache.org/viewvc/hadoop/core/trunk/build.xml?rev=772956&r1=772955&r2=772956&view=diff ============================================================================== --- hadoop/core/trunk/build.xml (original) +++ hadoop/core/trunk/build.xml Fri May 8 12:26:11 2009 @@ -96,8 +96,8 @@ - - + + @@ -111,6 +111,15 @@ + + + + + + + + + @@ -215,10 +224,15 @@ - + + + + + - + @@ -231,6 +245,21 @@ + + + + + + + + + + + + + + + @@ -275,8 +304,6 @@ - - @@ -621,98 +648,182 @@ - + + - + - - + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + encoding="${build.encoding}" + srcdir="${test.src.dir}/mapred/testjar" + includes="*.java" + destdir="${test.mapred.build.testjar}" + debug="${javac.debug}" + optimize="${javac.optimize}" + target="${javac.version}" + source="${javac.version}" + deprecation="${javac.deprecation}"> - - - - + + + + + + - - - - - - - - - - - - - - - - - - - - - - - - - - - - + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + - + + + + + + + + + + + + + @@ -730,7 +841,7 @@ - + @@ -760,29 +871,182 @@ - + - - + - Tests failed! + Tests failed! - + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + Tests failed! + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + Tests failed! + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + Tests failed! + + + - - + + + + + + + + + + + + + + + + + + + + + + + + Modified: hadoop/core/trunk/src/contrib/build-contrib.xml URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/build-contrib.xml?rev=772956&r1=772955&r2=772956&view=diff ============================================================================== --- hadoop/core/trunk/src/contrib/build-contrib.xml (original) +++ hadoop/core/trunk/src/contrib/build-contrib.xml Fri May 8 12:26:11 2009 @@ -93,6 +93,9 @@ + + + Modified: hadoop/core/trunk/src/contrib/hdfsproxy/build.xml URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/hdfsproxy/build.xml?rev=772956&r1=772955&r2=772956&view=diff ============================================================================== --- hadoop/core/trunk/src/contrib/hdfsproxy/build.xml (original) +++ hadoop/core/trunk/src/contrib/hdfsproxy/build.xml Fri May 8 12:26:11 2009 @@ -440,6 +440,9 @@ + + + Copied: hadoop/core/trunk/src/test/core/org/apache/hadoop/cli/TestCLI.java (from r772918, hadoop/core/trunk/src/test/org/apache/hadoop/cli/TestCLI.java) URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/test/core/org/apache/hadoop/cli/TestCLI.java?p2=hadoop/core/trunk/src/test/core/org/apache/hadoop/cli/TestCLI.java&p1=hadoop/core/trunk/src/test/org/apache/hadoop/cli/TestCLI.java&r1=772918&r2=772956&rev=772956&view=diff ============================================================================== --- hadoop/core/trunk/src/test/org/apache/hadoop/cli/TestCLI.java (original) +++ hadoop/core/trunk/src/test/core/org/apache/hadoop/cli/TestCLI.java Fri May 8 12:26:11 2009 @@ -36,8 +36,6 @@ import org.apache.hadoop.cli.util.CLITestData.TestCmd.CommandType; import org.apache.hadoop.cli.util.CommandExecutor.Result; import org.apache.hadoop.conf.Configuration; -import org.apache.hadoop.security.authorize.HadoopPolicyProvider; -import org.apache.hadoop.security.authorize.PolicyProvider; import org.apache.hadoop.security.authorize.ServiceAuthorizationManager; import org.apache.hadoop.util.StringUtils; import org.xml.sax.Attributes; @@ -107,8 +105,6 @@ readTestConfigFile(); conf = new Configuration(); - conf.setClass(PolicyProvider.POLICY_PROVIDER_CONFIG, - HadoopPolicyProvider.class, PolicyProvider.class); conf.setBoolean(ServiceAuthorizationManager.SERVICE_AUTHORIZATION_CONFIG, true); Copied: hadoop/core/trunk/src/test/core/org/apache/hadoop/test/CoreTestDriver.java (from r772918, hadoop/core/trunk/src/test/org/apache/hadoop/test/CoreTestDriver.java) URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/test/core/org/apache/hadoop/test/CoreTestDriver.java?p2=hadoop/core/trunk/src/test/core/org/apache/hadoop/test/CoreTestDriver.java&p1=hadoop/core/trunk/src/test/org/apache/hadoop/test/CoreTestDriver.java&r1=772918&r2=772956&rev=772956&view=diff ============================================================================== --- hadoop/core/trunk/src/test/org/apache/hadoop/test/CoreTestDriver.java (original) +++ hadoop/core/trunk/src/test/core/org/apache/hadoop/test/CoreTestDriver.java Fri May 8 12:26:11 2009 @@ -19,7 +19,6 @@ package org.apache.hadoop.test; import org.apache.hadoop.io.TestArrayFile; -import org.apache.hadoop.io.TestSequenceFile; import org.apache.hadoop.io.TestSetFile; import org.apache.hadoop.ipc.TestIPC; import org.apache.hadoop.ipc.TestRPC; @@ -39,8 +38,6 @@ public CoreTestDriver(ProgramDriver pgd) { this.pgd = pgd; try { - pgd.addClass("testsequencefile", TestSequenceFile.class, - "A test for flat files of binary key value pairs."); pgd.addClass("testsetfile", TestSetFile.class, "A test for flat files of binary key/value pairs."); pgd.addClass("testarrayfile", TestArrayFile.class, Copied: hadoop/core/trunk/src/test/core/org/apache/hadoop/util/TestProcfsBasedProcessTree.java (from r772918, hadoop/core/trunk/src/test/org/apache/hadoop/util/TestProcfsBasedProcessTree.java) URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/test/core/org/apache/hadoop/util/TestProcfsBasedProcessTree.java?p2=hadoop/core/trunk/src/test/core/org/apache/hadoop/util/TestProcfsBasedProcessTree.java&p1=hadoop/core/trunk/src/test/org/apache/hadoop/util/TestProcfsBasedProcessTree.java&r1=772918&r2=772956&rev=772956&view=diff ============================================================================== --- hadoop/core/trunk/src/test/org/apache/hadoop/util/TestProcfsBasedProcessTree.java (original) +++ hadoop/core/trunk/src/test/core/org/apache/hadoop/util/TestProcfsBasedProcessTree.java Fri May 8 12:26:11 2009 @@ -18,7 +18,10 @@ package org.apache.hadoop.util; +import java.io.BufferedReader; import java.io.File; +import java.io.FileNotFoundException; +import java.io.FileReader; import java.io.FileWriter; import java.io.IOException; import java.util.Random; @@ -29,7 +32,6 @@ import org.apache.hadoop.fs.Path; import org.apache.hadoop.util.Shell.ExitCodeException; import org.apache.hadoop.util.Shell.ShellCommandExecutor; -import org.apache.hadoop.mapred.UtilsForTests; import junit.framework.TestCase; @@ -84,7 +86,7 @@ } // read from pidFile - return UtilsForTests.getPidFromPidFile(pidFile); + return getPidFromPidFile(pidFile); } public void testProcessTree() { @@ -184,4 +186,49 @@ .getCumulativeVmem() == 0); assertTrue(p.toString().equals("[ ]")); } + + /** + * Get PID from a pid-file. + * + * @param pidFileName + * Name of the pid-file. + * @return the PID string read from the pid-file. Returns null if the + * pidFileName points to a non-existing file or if read fails from the + * file. + */ + public static String getPidFromPidFile(String pidFileName) { + BufferedReader pidFile = null; + FileReader fReader = null; + String pid = null; + + try { + fReader = new FileReader(pidFileName); + pidFile = new BufferedReader(fReader); + } catch (FileNotFoundException f) { + LOG.debug("PidFile doesn't exist : " + pidFileName); + return pid; + } + + try { + pid = pidFile.readLine(); + } catch (IOException i) { + LOG.error("Failed to read from " + pidFileName); + } finally { + try { + if (fReader != null) { + fReader.close(); + } + try { + if (pidFile != null) { + pidFile.close(); + } + } catch (IOException i) { + LOG.warn("Error closing the stream " + pidFile); + } + } catch (IOException i) { + LOG.warn("Error closing the stream " + fReader); + } + } + return pid; + } } Copied: hadoop/core/trunk/src/test/hdfs/org/apache/hadoop/cli/TestHDFSCLI.java (from r772918, hadoop/core/trunk/src/test/org/apache/hadoop/cli/TestHDFSCLI.java) URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/test/hdfs/org/apache/hadoop/cli/TestHDFSCLI.java?p2=hadoop/core/trunk/src/test/hdfs/org/apache/hadoop/cli/TestHDFSCLI.java&p1=hadoop/core/trunk/src/test/org/apache/hadoop/cli/TestHDFSCLI.java&r1=772918&r2=772956&rev=772956&view=diff ============================================================================== --- hadoop/core/trunk/src/test/org/apache/hadoop/cli/TestHDFSCLI.java (original) +++ hadoop/core/trunk/src/test/hdfs/org/apache/hadoop/cli/TestHDFSCLI.java Fri May 8 12:26:11 2009 @@ -24,8 +24,10 @@ import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.FsShell; import org.apache.hadoop.hdfs.DistributedFileSystem; +import org.apache.hadoop.hdfs.HDFSPolicyProvider; import org.apache.hadoop.hdfs.MiniDFSCluster; import org.apache.hadoop.hdfs.tools.DFSAdmin; +import org.apache.hadoop.security.authorize.PolicyProvider; import org.apache.hadoop.util.ToolRunner; public class TestHDFSCLI extends TestCLI{ @@ -38,6 +40,9 @@ public void setUp() throws Exception { super.setUp(); + conf.setClass(PolicyProvider.POLICY_PROVIDER_CONFIG, + HDFSPolicyProvider.class, PolicyProvider.class); + // Many of the tests expect a replication value of 1 in the output conf.setInt("dfs.replication", 1); Copied: hadoop/core/trunk/src/test/hdfs/org/apache/hadoop/fs/ftp/TestFTPFileSystem.java (from r772918, hadoop/core/trunk/src/test/org/apache/hadoop/fs/ftp/TestFTPFileSystem.java) URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/test/hdfs/org/apache/hadoop/fs/ftp/TestFTPFileSystem.java?p2=hadoop/core/trunk/src/test/hdfs/org/apache/hadoop/fs/ftp/TestFTPFileSystem.java&p1=hadoop/core/trunk/src/test/org/apache/hadoop/fs/ftp/TestFTPFileSystem.java&r1=772918&r2=772956&rev=772956&view=diff ============================================================================== --- hadoop/core/trunk/src/test/org/apache/hadoop/fs/ftp/TestFTPFileSystem.java (original) +++ hadoop/core/trunk/src/test/hdfs/org/apache/hadoop/fs/ftp/TestFTPFileSystem.java Fri May 8 12:26:11 2009 @@ -32,7 +32,6 @@ import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.FileUtil; import org.apache.hadoop.fs.Path; -import org.apache.hadoop.mapred.JobConf; /** * Generates a bunch of random files and directories using class 'DFSTestUtil', @@ -41,7 +40,7 @@ */ public class TestFTPFileSystem extends TestCase { - private Configuration defaultConf = new JobConf(); + private Configuration defaultConf = new Configuration(); private FtpServer server = null; private FileSystem localFs = null; private FileSystem ftpFs = null; Copied: hadoop/core/trunk/src/test/mapred/org/apache/hadoop/cli/TestMRCLI.java (from r772918, hadoop/core/trunk/src/test/org/apache/hadoop/cli/TestMRCLI.java) URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/test/mapred/org/apache/hadoop/cli/TestMRCLI.java?p2=hadoop/core/trunk/src/test/mapred/org/apache/hadoop/cli/TestMRCLI.java&p1=hadoop/core/trunk/src/test/org/apache/hadoop/cli/TestMRCLI.java&r1=772918&r2=772956&rev=772956&view=diff ============================================================================== --- hadoop/core/trunk/src/test/org/apache/hadoop/cli/TestMRCLI.java (original) +++ hadoop/core/trunk/src/test/mapred/org/apache/hadoop/cli/TestMRCLI.java Fri May 8 12:26:11 2009 @@ -25,6 +25,8 @@ import org.apache.hadoop.mapred.JobConf; import org.apache.hadoop.mapred.MiniMRCluster; import org.apache.hadoop.mapred.tools.MRAdmin; +import org.apache.hadoop.security.authorize.HadoopPolicyProvider; +import org.apache.hadoop.security.authorize.PolicyProvider; import org.apache.hadoop.util.ToolRunner; public class TestMRCLI extends TestHDFSCLI{ @@ -36,6 +38,8 @@ public void setUp() throws Exception { super.setUp(); + conf.setClass(PolicyProvider.POLICY_PROVIDER_CONFIG, + HadoopPolicyProvider.class, PolicyProvider.class); JobConf mrConf = new JobConf(conf); mrCluster = new MiniMRCluster(1, dfsCluster.getFileSystem().getUri().toString(), 1, null, null, mrConf); Modified: hadoop/core/trunk/src/test/mapred/org/apache/hadoop/mapred/TestCommandLineJobSubmission.java URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/test/mapred/org/apache/hadoop/mapred/TestCommandLineJobSubmission.java?rev=772956&r1=772918&r2=772956&view=diff ============================================================================== --- hadoop/core/trunk/src/test/mapred/org/apache/hadoop/mapred/TestCommandLineJobSubmission.java (original) +++ hadoop/core/trunk/src/test/mapred/org/apache/hadoop/mapred/TestCommandLineJobSubmission.java Fri May 8 12:26:11 2009 @@ -65,7 +65,7 @@ args[2] = "-libjars"; // the testjob.jar as a temporary jar file // rather than creating its own - args[3] = "build/test/testjar/testjob.jar"; + args[3] = "build/test/mapred/testjar/testjob.jar"; args[4] = input.toString(); args[5] = output.toString(); Modified: hadoop/core/trunk/src/test/mapred/org/apache/hadoop/mapred/TestCustomOutputCommitter.java URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/test/mapred/org/apache/hadoop/mapred/TestCustomOutputCommitter.java?rev=772956&r1=772918&r2=772956&view=diff ============================================================================== --- hadoop/core/trunk/src/test/mapred/org/apache/hadoop/mapred/TestCustomOutputCommitter.java (original) +++ hadoop/core/trunk/src/test/mapred/org/apache/hadoop/mapred/TestCustomOutputCommitter.java Fri May 8 12:26:11 2009 @@ -48,7 +48,7 @@ args[0] = "-libjars"; // the testjob.jar as a temporary jar file // holding custom output committer - args[1] = "build/test/testjar/testjob.jar"; + args[1] = "build/test/mapred/testjar/testjob.jar"; args[2] = "-D"; args[3] = "mapred.output.committer.class=testjar.CustomOutputCommitter"; args[4] = input.toString(); Modified: hadoop/core/trunk/src/test/mapred/org/apache/hadoop/mapred/TestKillSubProcesses.java URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/test/mapred/org/apache/hadoop/mapred/TestKillSubProcesses.java?rev=772956&r1=772918&r2=772956&view=diff ============================================================================== --- hadoop/core/trunk/src/test/mapred/org/apache/hadoop/mapred/TestKillSubProcesses.java (original) +++ hadoop/core/trunk/src/test/mapred/org/apache/hadoop/mapred/TestKillSubProcesses.java Fri May 8 12:26:11 2009 @@ -34,6 +34,7 @@ import org.apache.hadoop.util.StringUtils; import org.apache.hadoop.util.ProcessTree; import org.apache.hadoop.util.Shell; +import org.apache.hadoop.util.TestProcfsBasedProcessTree; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; @@ -189,7 +190,7 @@ // Checking if the descendant processes of map task are alive if(ProcessTree.isSetsidAvailable) { - String childPid = UtilsForTests.getPidFromPidFile( + String childPid = TestProcfsBasedProcessTree.getPidFromPidFile( scriptDirName + "/childPidFile" + 0); while(childPid == null) { LOG.warn(scriptDirName + "/childPidFile" + 0 + " is null; Sleeping..."); @@ -199,7 +200,7 @@ LOG.warn("sleep is interrupted:" + ie); break; } - childPid = UtilsForTests.getPidFromPidFile( + childPid = TestProcfsBasedProcessTree.getPidFromPidFile( scriptDirName + "/childPidFile" + 0); } @@ -208,7 +209,7 @@ // have been created already(See the script for details). // Now check if the descendants of map task are alive. for(int i=0; i <= numLevelsOfSubProcesses; i++) { - childPid = UtilsForTests.getPidFromPidFile( + childPid = TestProcfsBasedProcessTree.getPidFromPidFile( scriptDirName + "/childPidFile" + i); LOG.info("pid of the descendant process at level " + i + "in the subtree of processes(with the map task as the root)" + @@ -242,7 +243,7 @@ // Checking if the descendant processes of map task are killed properly if(ProcessTree.isSetsidAvailable) { for(int i=0; i <= numLevelsOfSubProcesses; i++) { - String childPid = UtilsForTests.getPidFromPidFile( + String childPid = TestProcfsBasedProcessTree.getPidFromPidFile( scriptDirName + "/childPidFile" + i); LOG.info("pid of the descendant process at level " + i + "in the subtree of processes(with the map task as the root)" + @@ -343,7 +344,7 @@ Runtime.getRuntime() .exec(shellScript + " " + numLevelsOfSubProcesses); - String childPid = UtilsForTests.getPidFromPidFile(scriptDir + String childPid = TestProcfsBasedProcessTree.getPidFromPidFile(scriptDir + "/childPidFile" + 0); while (childPid == null) { LOG.warn(scriptDir + "/childPidFile" + 0 + " is null; Sleeping..."); @@ -353,7 +354,7 @@ LOG.warn("sleep is interrupted:" + ie); break; } - childPid = UtilsForTests.getPidFromPidFile(scriptDir + childPid = TestProcfsBasedProcessTree.getPidFromPidFile(scriptDir + "/childPidFile" + 0); } } Modified: hadoop/core/trunk/src/test/mapred/org/apache/hadoop/mapred/TestMiniMRClasspath.java URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/test/mapred/org/apache/hadoop/mapred/TestMiniMRClasspath.java?rev=772956&r1=772918&r2=772956&view=diff ============================================================================== --- hadoop/core/trunk/src/test/mapred/org/apache/hadoop/mapred/TestMiniMRClasspath.java (original) +++ hadoop/core/trunk/src/test/mapred/org/apache/hadoop/mapred/TestMiniMRClasspath.java Fri May 8 12:26:11 2009 @@ -73,7 +73,7 @@ conf.setNumMapTasks(numMaps); conf.setNumReduceTasks(numReduces); //pass a job.jar already included in the hadoop build - conf.setJar("build/test/testjar/testjob.jar"); + conf.setJar("build/test/mapred/testjar/testjob.jar"); JobClient.runJob(conf); StringBuffer result = new StringBuffer(); { @@ -130,7 +130,7 @@ conf.set("mapred.reducer.class", "testjar.ExternalMapperReducer"); //pass a job.jar already included in the hadoop build - conf.setJar("build/test/testjar/testjob.jar"); + conf.setJar("build/test/mapred/testjar/testjob.jar"); JobClient.runJob(conf); StringBuffer result = new StringBuffer(); Path[] fileList = FileUtil.stat2Paths(fs.listStatus(outDir, Modified: hadoop/core/trunk/src/test/mapred/org/apache/hadoop/mapred/TestRackAwareTaskPlacement.java URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/test/mapred/org/apache/hadoop/mapred/TestRackAwareTaskPlacement.java?rev=772956&r1=772918&r2=772956&view=diff ============================================================================== --- hadoop/core/trunk/src/test/mapred/org/apache/hadoop/mapred/TestRackAwareTaskPlacement.java (original) +++ hadoop/core/trunk/src/test/mapred/org/apache/hadoop/mapred/TestRackAwareTaskPlacement.java Fri May 8 12:26:11 2009 @@ -175,7 +175,7 @@ jobConf.setOutputValueClass(BytesWritable.class); jobConf.setNumMapTasks(numMaps); jobConf.setNumReduceTasks(0); - jobConf.setJar("build/test/testjar/testjob.jar"); + jobConf.setJar("build/test/mapred/testjar/testjob.jar"); return JobClient.runJob(jobConf); } } Modified: hadoop/core/trunk/src/test/mapred/org/apache/hadoop/mapred/UtilsForTests.java URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/test/mapred/org/apache/hadoop/mapred/UtilsForTests.java?rev=772956&r1=772918&r2=772956&view=diff ============================================================================== --- hadoop/core/trunk/src/test/mapred/org/apache/hadoop/mapred/UtilsForTests.java (original) +++ hadoop/core/trunk/src/test/mapred/org/apache/hadoop/mapred/UtilsForTests.java Fri May 8 12:26:11 2009 @@ -295,7 +295,7 @@ jobConf.setInputFormat(RandomInputFormat.class); jobConf.setNumMapTasks(numMaps); jobConf.setNumReduceTasks(numRed); - jobConf.setJar("build/test/testjar/testjob.jar"); + jobConf.setJar("build/test/mapred/testjar/testjob.jar"); jobConf.set(getTaskSignalParameter(true), mapSignalFilename); jobConf.set(getTaskSignalParameter(false), redSignalFilename); } @@ -686,48 +686,4 @@ fos.close(); } - /** - * Get PID from a pid-file. - * - * @param pidFileName - * Name of the pid-file. - * @return the PID string read from the pid-file. Returns null if the - * pidFileName points to a non-existing file or if read fails from the - * file. - */ - public static String getPidFromPidFile(String pidFileName) { - BufferedReader pidFile = null; - FileReader fReader = null; - String pid = null; - - try { - fReader = new FileReader(pidFileName); - pidFile = new BufferedReader(fReader); - } catch (FileNotFoundException f) { - LOG.debug("PidFile doesn't exist : " + pidFileName); - return pid; - } - - try { - pid = pidFile.readLine(); - } catch (IOException i) { - LOG.error("Failed to read from " + pidFileName); - } finally { - try { - if (fReader != null) { - fReader.close(); - } - try { - if (pidFile != null) { - pidFile.close(); - } - } catch (IOException i) { - LOG.warn("Error closing the stream " + pidFile); - } - } catch (IOException i) { - LOG.warn("Error closing the stream " + fReader); - } - } - return pid; - } } Copied: hadoop/core/trunk/src/test/mapred/org/apache/hadoop/test/MapredTestDriver.java (from r772918, hadoop/core/trunk/src/test/org/apache/hadoop/test/MapredTestDriver.java) URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/test/mapred/org/apache/hadoop/test/MapredTestDriver.java?p2=hadoop/core/trunk/src/test/mapred/org/apache/hadoop/test/MapredTestDriver.java&p1=hadoop/core/trunk/src/test/org/apache/hadoop/test/MapredTestDriver.java&r1=772918&r2=772956&rev=772956&view=diff ============================================================================== --- hadoop/core/trunk/src/test/org/apache/hadoop/test/MapredTestDriver.java (original) +++ hadoop/core/trunk/src/test/mapred/org/apache/hadoop/test/MapredTestDriver.java Fri May 8 12:26:11 2009 @@ -18,6 +18,7 @@ package org.apache.hadoop.test; +import org.apache.hadoop.io.TestSequenceFile; import org.apache.hadoop.mapred.BigMapOutput; import org.apache.hadoop.mapred.GenericMRLoadGenerator; import org.apache.hadoop.mapred.MRBench; @@ -44,6 +45,8 @@ public MapredTestDriver(ProgramDriver pgd) { this.pgd = pgd; try { + pgd.addClass("testsequencefile", TestSequenceFile.class, + "A test for flat files of binary key value pairs."); pgd.addClass("threadedmapbench", ThreadedMapBenchmark.class, "A map/reduce benchmark that compares the performance " + "of maps with multiple spills over maps with 1 spill");