Repository: hadoop Updated Branches: refs/heads/branch-2 7f075f2b7 -> 37ad3b3fe
MAPREDUCE-6383. Pi job (QuasiMonteCarlo) should not try to read the results file if its job fails. Contributed by Harsh J. (cherry picked from commit 09b8241e6e369ee00241efcc2e048e710dbcccd1) Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/37ad3b3f Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/37ad3b3f Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/37ad3b3f Branch: refs/heads/branch-2 Commit: 37ad3b3fef233a118ecf898e1f0ae54ef9f158c9 Parents: 7f075f2 Author: Devaraj K <[email protected]> Authored: Fri Jun 5 21:22:47 2015 +0530 Committer: Devaraj K <[email protected]> Committed: Fri Jun 5 21:23:48 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/37ad3b3f/hadoop-mapreduce-project/CHANGES.txt ---------------------------------------------------------------------- diff --git a/hadoop-mapreduce-project/CHANGES.txt b/hadoop-mapreduce-project/CHANGES.txt index 346d5f1..30a2666 100644 --- a/hadoop-mapreduce-project/CHANGES.txt +++ b/hadoop-mapreduce-project/CHANGES.txt @@ -76,6 +76,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/37ad3b3f/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");
