You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gobblin.apache.org by ab...@apache.org on 2018/03/21 08:30:55 UTC
[37/50] incubator-gobblin git commit: [GOBBLIN-415] Check for the
value of configuration key flow.runImmediately in Job config.
[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 <su...@linkedin.biz>
Authored: Thu Feb 22 08:22:45 2018 -0800
Committer: Hung Tran <hu...@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));
}