This is an automated email from the ASF dual-hosted git repository.

hutran 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 69147f8  [GOBBLIN-783] Fix the double referencing issue for job type 
config.
69147f8 is described below

commit 69147f8c3211c0ab6f92338f6b9cbe962a4672e3
Author: Kuai Yu <[email protected]>
AuthorDate: Tue May 28 13:40:05 2019 -0700

    [GOBBLIN-783] Fix the double referencing issue for job type config.
    
    Closes #2646 from yukuai518/bug2
---
 .../main/java/org/apache/gobblin/cluster/GobblinHelixJobLauncher.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixJobLauncher.java
 
b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixJobLauncher.java
index 732c7d3..6d41cc7 100644
--- 
a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixJobLauncher.java
+++ 
b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixJobLauncher.java
@@ -322,7 +322,7 @@ public class GobblinHelixJobLauncher extends 
AbstractJobLauncher {
     }
 
     if 
(this.jobConfig.hasPath(GobblinClusterConfigurationKeys.HELIX_JOB_TYPE_KEY)) {
-      String jobType = 
this.jobConfig.getString(this.jobConfig.getString(GobblinClusterConfigurationKeys.HELIX_JOB_TYPE_KEY));
+      String jobType = 
this.jobConfig.getString(GobblinClusterConfigurationKeys.HELIX_JOB_TYPE_KEY);
       log.info("Job {} has types associated : {}", this.jobContext.getJobId(), 
jobType);
       jobConfigBuilder.setJobType(jobType);
     }

Reply via email to