You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gobblin.apache.org by ib...@apache.org on 2018/01/16 23:02:09 UTC
incubator-gobblin git commit: [GOBBLIN-367] Adding mrJob object as a
field in MRTask so that inherited Task could read jobUrl from it
Repository: incubator-gobblin
Updated Branches:
refs/heads/master 4bdd0482e -> 4e9c8d5ed
[GOBBLIN-367] Adding mrJob object as a field in MRTask so that inherited Task could read jobUrl from it
Closes #2240 from autumnust/jobfieldinmrtask
Project: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/commit/4e9c8d5e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/tree/4e9c8d5e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/diff/4e9c8d5e
Branch: refs/heads/master
Commit: 4e9c8d5edef05f41420a935e12336d462d5dab85
Parents: 4bdd048
Author: Lei Sun <au...@gmail.com>
Authored: Tue Jan 16 15:02:01 2018 -0800
Committer: Issac Buenrostro <ib...@apache.org>
Committed: Tue Jan 16 15:02:01 2018 -0800
----------------------------------------------------------------------
.../src/main/java/org/apache/gobblin/runtime/mapreduce/MRTask.java | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/4e9c8d5e/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 98256fe..3abee65 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
@@ -62,6 +62,7 @@ public class MRTask extends BaseAbstractTask {
private final TaskContext taskContext;
private final EventSubmitter eventSubmitter;
+ protected Job mrJob;
public MRTask(TaskContext taskContext) {
super(taskContext);
@@ -95,6 +96,7 @@ public class MRTask extends BaseAbstractTask {
job.submit();
this.eventSubmitter.submit(Events.MR_JOB_STARTED_EVENT, Events.JOB_URL, job.getTrackingURL());
job.waitForCompletion(false);
+ this.mrJob = job;
if (job.isSuccessful()) {
this.eventSubmitter.submit(Events.MR_JOB_SUCCESSFUL, Events.JOB_URL, job.getTrackingURL());