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/06/14 20:45:49 UTC
svn commit: r190639 - in
/lucene/nutch/branches/mapred/src/java/org/apache/nutch/mapred:
JobClient.java RunningJob.java
Author: cutting
Date: Tue Jun 14 11:45:48 2005
New Revision: 190639
URL: http://svn.apache.org/viewcvs?rev=190639&view=rev
Log:
Translate job failures into an exception under JobClient.run().
Modified:
lucene/nutch/branches/mapred/src/java/org/apache/nutch/mapred/JobClient.java
lucene/nutch/branches/mapred/src/java/org/apache/nutch/mapred/RunningJob.java
Modified: lucene/nutch/branches/mapred/src/java/org/apache/nutch/mapred/JobClient.java
URL: http://svn.apache.org/viewcvs/lucene/nutch/branches/mapred/src/java/org/apache/nutch/mapred/JobClient.java?rev=190639&r1=190638&r2=190639&view=diff
==============================================================================
--- lucene/nutch/branches/mapred/src/java/org/apache/nutch/mapred/JobClient.java (original)
+++ lucene/nutch/branches/mapred/src/java/org/apache/nutch/mapred/JobClient.java Tue Jun 14 11:45:48 2005
@@ -121,6 +121,14 @@
}
/**
+ * True iff job completed successfully.
+ */
+ public synchronized boolean isSuccessful() throws IOException {
+ ensureFreshStatus();
+ return status.getRunState() == JobStatus.SUCCEEDED;
+ }
+
+ /**
* Blocks until the job is finished
*/
public synchronized void waitForCompletion() throws IOException {
@@ -292,6 +300,9 @@
LOG.info(" reduce "+Math.round(running.reduceProgress()*100)
+"% complete");
}
+ }
+ if (!running.isSuccessful()) {
+ throw new IOException("Job failed!");
}
LOG.info("Job complete: " + jobId);
error = false;
Modified: lucene/nutch/branches/mapred/src/java/org/apache/nutch/mapred/RunningJob.java
URL: http://svn.apache.org/viewcvs/lucene/nutch/branches/mapred/src/java/org/apache/nutch/mapred/RunningJob.java?rev=190639&r1=190638&r2=190639&view=diff
==============================================================================
--- lucene/nutch/branches/mapred/src/java/org/apache/nutch/mapred/RunningJob.java (original)
+++ lucene/nutch/branches/mapred/src/java/org/apache/nutch/mapred/RunningJob.java Tue Jun 14 11:45:48 2005
@@ -63,6 +63,11 @@
public boolean isComplete() throws IOException;
/**
+ * True iff job completed successfully.
+ */
+ public boolean isSuccessful() throws IOException;
+
+ /**
* Blocks until the job is complete.
*/
public void waitForCompletion() throws IOException;