This is an automated email from the ASF dual-hosted git repository.
suvasude 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 ea524ed [GOBBLIN-905] Fixes issue where newly added jobs would crash
in gobblin standalone's job conf folder
ea524ed is described below
commit ea524ed1c9d49d430bfdd744240840c0bbd53eda
Author: William Lo <[email protected]>
AuthorDate: Thu Oct 10 20:57:49 2019 -0700
[GOBBLIN-905] Fixes issue where newly added jobs would crash in gobblin
standalone's job conf folder
Closes #2759 from Will-Lo/fix-folder-tracking-
null-pointer-bug
---
.../src/main/java/org/apache/gobblin/scheduler/JobScheduler.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/JobScheduler.java
b/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/JobScheduler.java
index fe3640a..ada9bdd 100644
---
a/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/JobScheduler.java
+++
b/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/JobScheduler.java
@@ -168,6 +168,8 @@ public class JobScheduler extends AbstractIdleService {
this.properties.getProperty(ConfigurationKeys.SCHEDULER_WAIT_FOR_JOB_COMPLETION_KEY,
ConfigurationKeys.DEFAULT_SCHEDULER_WAIT_FOR_JOB_COMPLETION));
+ this.jobSpecResolver =
JobSpecResolver.builder(ConfigUtils.propertiesToConfig(properties)).build();
+
if
(this.properties.containsKey(ConfigurationKeys.JOB_CONFIG_FILE_GENERAL_PATH_KEY))
{
this.jobConfigFileDirPath = new
Path(this.properties.getProperty(ConfigurationKeys.JOB_CONFIG_FILE_GENERAL_PATH_KEY));
this.listener = new
PathAlterationListenerAdaptorForMonitor(jobConfigFileDirPath, this);
@@ -177,7 +179,6 @@ public class JobScheduler extends AbstractIdleService {
this.listener = null;
}
- this.jobSpecResolver =
JobSpecResolver.builder(ConfigUtils.propertiesToConfig(properties)).build();
}
@Override
