[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/0.12.0 Commit: 52bf10de714e14eddb7eb6ab2f54fb0cc3a1e341 Parents: b4597e9 Author: suvasude <[email protected]> Authored: Thu Feb 22 08:22:45 2018 -0800 Committer: Hung Tran <[email protected]> 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)); }
