From 3bef92045664d77e8d04e6a911010c0b98f5fb1a Mon Sep 17 00:00:00 2001
From: jarvis <jarvis@apache.org>
Date: Fri, 1 Nov 2024 14:38:47 +0800
Subject: [PATCH] [hotfix] fix config parse issue when integration with web

---
 .../core/starter/utils/ConfigShadeUtils.java  | 19 +++++++++++++++----
 1 file changed, 15 insertions(+), 4 deletions(-)

diff --git a/seatunnel-core/seatunnel-core-starter/src/main/java/org/apache/seatunnel/core/starter/utils/ConfigShadeUtils.java b/seatunnel-core/seatunnel-core-starter/src/main/java/org/apache/seatunnel/core/starter/utils/ConfigShadeUtils.java
index 3269ab8cd83..711e38949f9 100644
--- a/seatunnel-core/seatunnel-core-starter/src/main/java/org/apache/seatunnel/core/starter/utils/ConfigShadeUtils.java
+++ b/seatunnel-core/seatunnel-core-starter/src/main/java/org/apache/seatunnel/core/starter/utils/ConfigShadeUtils.java
@@ -34,6 +34,7 @@
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Base64;
+import java.util.Collections;
 import java.util.HashMap;
 import java.util.Iterator;
 import java.util.List;
@@ -139,10 +140,20 @@ private static Config processConfig(String identifier, Config config, boolean is
         String jsonString = config.root().render(ConfigRenderOptions.concise());
         ObjectNode jsonNodes = JsonUtils.parseObject(jsonString);
         Map<String, Object> configMap = JsonUtils.toMap(jsonNodes);
-        List<Map<String, Object>> sources =
-                (ArrayList<Map<String, Object>>) configMap.get(Constants.SOURCE);
-        List<Map<String, Object>> sinks =
-                (ArrayList<Map<String, Object>>) configMap.get(Constants.SINK);
+        Object sourceObj = configMap.get(Constants.SOURCE);
+        List<Map<String, Object>> sources;
+        if (sourceObj instanceof Map) {
+            sources = Collections.singletonList((Map<String, Object>) sourceObj);
+        } else {
+            sources = (ArrayList<Map<String, Object>>) sourceObj;
+        }
+        List<Map<String, Object>> sinks;
+        Object sinkObj = configMap.get(Constants.SINK);
+        if (sinkObj instanceof Map) {
+            sinks = Collections.singletonList((Map<String, Object>) sinkObj);
+        } else {
+            sinks = (ArrayList<Map<String, Object>>) sinkObj;
+        }
         Preconditions.checkArgument(
                 !sources.isEmpty(), "Miss <Source> config! Please check the config file.");
         Preconditions.checkArgument(