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);
}