You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nutch.apache.org by cu...@apache.org on 2005/09/08 20:09:31 UTC
svn commit: r279596 -
/lucene/nutch/branches/mapred/src/java/org/apache/nutch/mapred/JobTracker.java
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;
}