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 <[email protected]>
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()) {