[GOBBLIN-1849] Add Flow Group & Name to Job Config for Job Scheduler (#…

…3713) Co-authored-by: Urmi Mustafi <[email protected]>
apache · Jul 10, 2023 · 2c68476 · 2c68476
1 parent 3d14b86
commit 2c68476
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/...rc/main/java/org/apache/gobblin/service/modules/scheduler/GobblinServiceJobScheduler.java b/...rc/main/java/org/apache/gobblin/service/modules/scheduler/GobblinServiceJobScheduler.java
@@ -677,6 +677,13 @@ private Properties createJobConfig(FlowSpec flowSpec) {
           flowSpecProperties.getProperty(ConfigurationKeys.JOB_SCHEDULE_KEY));
     }
 
+    // Note: the default values for missing flow name/group are different than the ones above to easily identify where
+    // the values are not present initially
+    jobConfig.setProperty(ConfigurationKeys.FLOW_NAME_KEY,
+        flowSpecProperties.getProperty(ConfigurationKeys.FLOW_NAME_KEY, "<<missing flow name>>"));
+    jobConfig.setProperty(ConfigurationKeys.FLOW_GROUP_KEY,
+        flowSpecProperties.getProperty(ConfigurationKeys.FLOW_GROUP_KEY, "<<missing flow group>>"));
+
     return jobConfig;
   }