You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gobblin.apache.org by hu...@apache.org on 2018/04/21 02:36:41 UTC
incubator-gobblin git commit: [GOBBLIN-470] Enrich the log info for
MRTask
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 <au...@gmail.com>
Authored: Fri Apr 20 19:36:32 2018 -0700
Committer: Hung Tran <hu...@linkedin.com>
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);