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 <[email protected]> Authored: Tue Jan 16 15:02:01 2018 -0800 Committer: Issac Buenrostro <[email protected]> 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());
