You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gobblin.apache.org by le...@apache.org on 2020/08/18 23:02:13 UTC
[incubator-gobblin] branch master updated: [GOBBLIN-1232] One
liner: Enable verbose mode for waitForCompletion call
This is an automated email from the ASF dual-hosted git repository.
lesun pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-gobblin.git
The following commit(s) were added to refs/heads/master by this push:
new d29dd87 [GOBBLIN-1232] One liner: Enable verbose mode for waitForCompletion call
d29dd87 is described below
commit d29dd87c1c2ed72449c1ce99acbdbff4768a9dc0
Author: Lei Sun <au...@gmail.com>
AuthorDate: Tue Aug 18 16:01:56 2020 -0700
[GOBBLIN-1232] One liner: Enable verbose mode for waitForCompletion call
Closes #3077 from autumnust/moretracesmrtask
---
.../src/main/java/org/apache/gobblin/runtime/mapreduce/MRTask.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 05211f7..439b805 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
@@ -107,7 +107,7 @@ public class MRTask extends BaseAbstractTask {
log.info("MR tracking URL {} for job {}", job.getTrackingURL(), job.getJobName());
this.eventSubmitter.submit(Events.MR_JOB_STARTED_EVENT, Events.JOB_URL, job.getTrackingURL());
- job.waitForCompletion(false);
+ job.waitForCompletion(true);
this.mrJob = job;
if (job.isSuccessful()) {