Author: cutting Date: Thu Sep 8 11:09:28 2005 New Revision: 279596 URL: http://svn.apache.org/viewcvs?rev=279596&view=rev Log: Fix so that input splitting errors don't leave job hung.
Modified: lucene/nutch/branches/mapred/src/java/org/apache/nutch/mapred/JobTracker.java Modified: lucene/nutch/branches/mapred/src/java/org/apache/nutch/mapred/JobTracker.java URL: http://svn.apache.org/viewcvs/lucene/nutch/branches/mapred/src/java/org/apache/nutch/mapred/JobTracker.java?rev=279596&r1=279595&r2=279596&view=diff ============================================================================== --- lucene/nutch/branches/mapred/src/java/org/apache/nutch/mapred/JobTracker.java (original) +++ lucene/nutch/branches/mapred/src/java/org/apache/nutch/mapred/JobTracker.java Thu Sep 8 11:09:28 2005 @@ -521,7 +521,17 @@ JobInProgress createJob(String jobFile) throws IOException { JobInProgress job = new JobInProgress(jobFile); jobs.put(job.getProfile().getJobId(), job); - job.launch(); + + boolean error = true; + try { + job.launch(); + error = false; + } finally { + if (error) { + job.kill(); + } + } + return job; }