(gobblin) branch master updated: [GOBBLIN-2036] Fix type error where string config is forced into boolean type (#3915)

[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 3dffd9c39 [GOBBLIN-2036] Fix type error where string config is forced 
into boolean type (#3915)
3dffd9c39 is described below

commit 3dffd9c3913c1fddb08a5a238f63e5491df12722
Author: William Lo <lo.willia...@gmail.com>
AuthorDate: Thu Apr 4 14:31:14 2024 -0400

    [GOBBLIN-2036] Fix type error where string config is forced into boolean 
type (#3915)
---
 .../service/modules/utils/FlowCompilationValidationHelper.java        | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/utils/FlowCompilationValidationHelper.java
 
b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/utils/FlowCompilationValidationHelper.java
index 38e71acd7..4e9f48e5b 100644
--- 
a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/utils/FlowCompilationValidationHelper.java
+++ 
b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/utils/FlowCompilationValidationHelper.java
@@ -132,8 +132,8 @@ public class FlowCompilationValidationHelper {
    */
   public Optional<Dag<JobExecutionPlan>> 
validateAndHandleConcurrentExecution(Config flowConfig, FlowSpec flowSpec,
       String flowGroup, String flowName, Map<String,String> flowMetadata) 
throws IOException {
-    boolean allowConcurrentExecution = ConfigUtils.getBoolean(flowConfig,
-        ConfigurationKeys.FLOW_ALLOW_CONCURRENT_EXECUTION, 
isFlowConcurrencyEnabled);
+    boolean allowConcurrentExecution = 
Boolean.parseBoolean(ConfigUtils.getString(flowConfig,
+        ConfigurationKeys.FLOW_ALLOW_CONCURRENT_EXECUTION, 
String.valueOf(this.isFlowConcurrencyEnabled)));
 
     Dag<JobExecutionPlan> jobExecutionPlanDag = 
specCompiler.compileFlow(flowSpec);
     if (jobExecutionPlanDag.isEmpty()) {