Updated Branches: refs/heads/master 54efa1d6c -> dcf5d32b3
CRUNCH-288: Make it easier to identify the ID of the failing job in a long pipeline Project: http://git-wip-us.apache.org/repos/asf/crunch/repo Commit: http://git-wip-us.apache.org/repos/asf/crunch/commit/dcf5d32b Tree: http://git-wip-us.apache.org/repos/asf/crunch/tree/dcf5d32b Diff: http://git-wip-us.apache.org/repos/asf/crunch/diff/dcf5d32b Branch: refs/heads/master Commit: dcf5d32b38806bbf89b74887cbc3da8ca5b1ef82 Parents: 54efa1d Author: Josh Wills <[email protected]> Authored: Wed Oct 30 09:52:58 2013 -0700 Committer: Josh Wills <[email protected]> Committed: Wed Oct 30 09:52:58 2013 -0700 ---------------------------------------------------------------------- .../hadoop/mapreduce/lib/jobcontrol/CrunchControlledJob.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/crunch/blob/dcf5d32b/crunch-core/src/main/java/org/apache/crunch/hadoop/mapreduce/lib/jobcontrol/CrunchControlledJob.java ---------------------------------------------------------------------- diff --git a/crunch-core/src/main/java/org/apache/crunch/hadoop/mapreduce/lib/jobcontrol/CrunchControlledJob.java b/crunch-core/src/main/java/org/apache/crunch/hadoop/mapreduce/lib/jobcontrol/CrunchControlledJob.java index ab46263..aaf9f04 100644 --- a/crunch-core/src/main/java/org/apache/crunch/hadoop/mapreduce/lib/jobcontrol/CrunchControlledJob.java +++ b/crunch-core/src/main/java/org/apache/crunch/hadoop/mapreduce/lib/jobcontrol/CrunchControlledJob.java @@ -285,8 +285,7 @@ public class CrunchControlledJob implements MRJob { } if (s == State.FAILED || s == State.DEPENDENT_FAILED) { this.state = State.DEPENDENT_FAILED; - this.message = "depending job " + i + " with jobID " + pred.getJobID() - + " failed. " + pred.getMessage(); + this.message = "Depending job with jobID " + pred.getJobID() + " failed."; break; } // pred must be in success state
