Repository: incubator-gobblin Updated Branches: refs/heads/master 4cab75d15 -> 5f7246004
[GOBBLIN-218] Make sure cron scheduler works and tune schedule period Closes #2069 from abti/service Project: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/commit/5f724600 Tree: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/tree/5f724600 Diff: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/diff/5f724600 Branch: refs/heads/master Commit: 5f724600401dd6c7204a9d649c6316b04ad2bca6 Parents: 4cab75d Author: Abhishek Tiwari <[email protected]> Authored: Tue Aug 22 01:43:58 2017 -0700 Committer: Abhishek Tiwari <[email protected]> Committed: Tue Aug 22 01:45:02 2017 -0700 ---------------------------------------------------------------------- .../service/modules/scheduler/GobblinServiceJobScheduler.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/5f724600/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 c3c6a3f..d223f90 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 @@ -179,6 +179,8 @@ public class GobblinServiceJobScheduler extends JobScheduler implements SpecCata jobConfig.setProperty(ConfigurationKeys.JOB_NAME_KEY, addedSpec.getUri().toString()); jobConfig.setProperty(ConfigurationKeys.JOB_GROUP_KEY, ((FlowSpec) addedSpec).getConfig().getValue(ConfigurationKeys.FLOW_GROUP_KEY).toString()); + jobConfig.setProperty(ConfigurationKeys.FLOW_RUN_IMMEDIATELY, + ConfigUtils.getString(((FlowSpec) addedSpec).getConfig(), ConfigurationKeys.FLOW_RUN_IMMEDIATELY,"false")); if (flowSpecProperties.containsKey(ConfigurationKeys.JOB_SCHEDULE_KEY) && StringUtils.isNotBlank(flowSpecProperties.getProperty(ConfigurationKeys.JOB_SCHEDULE_KEY))) { jobConfig.setProperty(ConfigurationKeys.JOB_SCHEDULE_KEY, flowSpecProperties.getProperty(ConfigurationKeys.JOB_SCHEDULE_KEY));
