[gobblin] branch master updated: [GOBBLIN-1849] Add Flow Group & Name to Job Config for Job Scheduler (#3713)

[wlo]

This is an automated email from the ASF dual-hosted git repository.

wlo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/gobblin.git


The following commit(s) were added to refs/heads/master by this push:
     new 2c684767b [GOBBLIN-1849] Add Flow Group & Name to Job Config for Job 
Scheduler (#3713)
2c684767b is described below

commit 2c684767bd9402bbc55d7c2091f71faf8ef3fd77
Author: umustafi <umus...@gmail.com>
AuthorDate: Mon Jul 10 14:32:28 2023 -0700

    [GOBBLIN-1849] Add Flow Group & Name to Job Config for Job Scheduler (#3713)
    
    Co-authored-by: Urmi Mustafi <umust...@umustafi-mn1.linkedin.biz>
---
 .../service/modules/scheduler/GobblinServiceJobScheduler.java      | 7 +++++++
 1 file changed, 7 insertions(+)

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 5e0ac3988..d860ed485 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
@@ -677,6 +677,13 @@ public class GobblinServiceJobScheduler extends 
JobScheduler implements SpecCata
           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;
   }