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;