Repository: incubator-gobblin Updated Branches: refs/heads/master b11be3d60 -> 1447f2d3b
[GOBBLIN-470] Enrich the log info for MRTask Closes #2343 from autumnust/MRTaskLog Project: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/commit/1447f2d3 Tree: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/tree/1447f2d3 Diff: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/diff/1447f2d3 Branch: refs/heads/master Commit: 1447f2d3bbfb2def9a8692d533e2dd90a30d29b5 Parents: b11be3d Author: Lei Sun <[email protected]> Authored: Fri Apr 20 19:36:32 2018 -0700 Committer: Hung Tran <[email protected]> Committed: Fri Apr 20 19:36:32 2018 -0700 ---------------------------------------------------------------------- .../main/java/org/apache/gobblin/runtime/mapreduce/MRTask.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/1447f2d3/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/MRTask.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/MRTask.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/MRTask.java index a2e56d7..bae259c 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/MRTask.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/MRTask.java @@ -112,7 +112,8 @@ public class MRTask extends BaseAbstractTask { this.onMRTaskComplete(true, null); } else { this.eventSubmitter.submit(Events.MR_JOB_FAILED, Events.JOB_URL, job.getTrackingURL()); - this.onMRTaskComplete (false, new IOException("MR Job is not successful")); + this.onMRTaskComplete (false, + new IOException(String.format("MR Job:%s is not successful", job.getTrackingURL()))); } } catch (Throwable t) { log.error("Failed to run MR job.", t);
