Repository: incubator-gobblin
Updated Branches:
  refs/heads/master b4597e988 -> 52bf10de7


[GOBBLIN-415] Check for the value of configuration key flow.runImmediately in 
Job config.

Closes #2291 from sv2000/gobblin-415


Project: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/commit/52bf10de
Tree: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/tree/52bf10de
Diff: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/diff/52bf10de

Branch: refs/heads/master
Commit: 52bf10de714e14eddb7eb6ab2f54fb0cc3a1e341
Parents: b4597e9
Author: suvasude <suvas...@linkedin.biz>
Authored: Thu Feb 22 08:22:45 2018 -0800
Committer: Hung Tran <hut...@linkedin.com>
Committed: Thu Feb 22 08:22:45 2018 -0800

----------------------------------------------------------------------
 .../service/modules/scheduler/GobblinServiceJobScheduler.java     | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/52bf10de/gobblin-service/src/main/java/org/apache/gobblin/service/modules/scheduler/GobblinServiceJobScheduler.java
----------------------------------------------------------------------
diff --git 
a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/scheduler/GobblinServiceJobScheduler.java
 
b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/scheduler/GobblinServiceJobScheduler.java
index 9cb39fb..ae18fc2 100644
--- 
a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/scheduler/GobblinServiceJobScheduler.java
+++ 
b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/scheduler/GobblinServiceJobScheduler.java
@@ -61,6 +61,7 @@ import org.apache.gobblin.service.modules.utils.HelixUtils;
 import org.apache.gobblin.service.ServiceConfigKeys;
 import org.apache.gobblin.service.modules.orchestration.Orchestrator;
 import org.apache.gobblin.util.ConfigUtils;
+import org.apache.gobblin.util.PropertiesUtils;
 
 
 /**
@@ -222,7 +223,7 @@ public class GobblinServiceJobScheduler extends 
JobScheduler implements SpecCata
         if (jobConfig.containsKey(ConfigurationKeys.JOB_SCHEDULE_KEY)) {
           _log.info("Scheduling flow spec: " + addedSpec);
           scheduleJob(jobConfig, null);
-          if (jobConfig.containsKey(ConfigurationKeys.FLOW_RUN_IMMEDIATELY)) {
+          if (PropertiesUtils.getPropAsBoolean(jobConfig, 
ConfigurationKeys.FLOW_RUN_IMMEDIATELY, "false")) {
             _log.info("RunImmediately requested, hence executing FlowSpec: " + 
addedSpec);
             this.jobExecutor.execute(new NonScheduledJobRunner(jobConfig, 
null));
           }

Reply via email to