hadoop-common-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From deva...@apache.org
Subject hadoop git commit: MAPREDUCE-6383. Pi job (QuasiMonteCarlo) should not try to read the results file if its job fails. Contributed by Harsh J.
Date Fri, 05 Jun 2015 15:54:43 GMT
Repository: hadoop
Updated Branches:
  refs/heads/trunk 790a86176 -> 09b8241e6


MAPREDUCE-6383. Pi job (QuasiMonteCarlo) should not try to read the
results file if its job fails. Contributed by Harsh J.


Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/09b8241e
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/09b8241e
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/09b8241e

Branch: refs/heads/trunk
Commit: 09b8241e6e369ee00241efcc2e048e710dbcccd1
Parents: 790a861
Author: Devaraj K <devaraj@apache.org>
Authored: Fri Jun 5 21:22:47 2015 +0530
Committer: Devaraj K <devaraj@apache.org>
Committed: Fri Jun 5 21:22:47 2015 +0530

----------------------------------------------------------------------
 hadoop-mapreduce-project/CHANGES.txt                             | 3 +++
 .../main/java/org/apache/hadoop/examples/QuasiMonteCarlo.java    | 4 ++++
 2 files changed, 7 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hadoop/blob/09b8241e/hadoop-mapreduce-project/CHANGES.txt
----------------------------------------------------------------------
diff --git a/hadoop-mapreduce-project/CHANGES.txt b/hadoop-mapreduce-project/CHANGES.txt
index 2ffa541..1813c31 100644
--- a/hadoop-mapreduce-project/CHANGES.txt
+++ b/hadoop-mapreduce-project/CHANGES.txt
@@ -337,6 +337,9 @@ Release 2.8.0 - UNRELEASED
     MAPREDUCE-6174. Combine common stream code into parent class for
     InMemoryMapOutput and OnDiskMapOutput. (Eric Payne via gera)
 
+    MAPREDUCE-6383. Pi job (QuasiMonteCarlo) should not try to read the 
+    results file if its job fails. (Harsh J via devaraj)
+
   OPTIMIZATIONS
 
   BUG FIXES

http://git-wip-us.apache.org/repos/asf/hadoop/blob/09b8241e/hadoop-mapreduce-project/hadoop-mapreduce-examples/src/main/java/org/apache/hadoop/examples/QuasiMonteCarlo.java
----------------------------------------------------------------------
diff --git a/hadoop-mapreduce-project/hadoop-mapreduce-examples/src/main/java/org/apache/hadoop/examples/QuasiMonteCarlo.java
b/hadoop-mapreduce-project/hadoop-mapreduce-examples/src/main/java/org/apache/hadoop/examples/QuasiMonteCarlo.java
index 25dee6b..1a0c372 100644
--- a/hadoop-mapreduce-project/hadoop-mapreduce-examples/src/main/java/org/apache/hadoop/examples/QuasiMonteCarlo.java
+++ b/hadoop-mapreduce-project/hadoop-mapreduce-examples/src/main/java/org/apache/hadoop/examples/QuasiMonteCarlo.java
@@ -304,6 +304,10 @@ public class QuasiMonteCarlo extends Configured implements Tool {
       System.out.println("Starting Job");
       final long startTime = System.currentTimeMillis();
       job.waitForCompletion(true);
+      if (!job.isSuccessful()) {
+        System.out.println("Job " + job.getJobID() + " failed!");
+        System.exit(1);
+      }
       final double duration = (System.currentTimeMillis() - startTime)/1000.0;
       System.out.println("Job Finished in " + duration + " seconds");
 


Mime
View raw message