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()) {