解决yarn application 解析数组异常

dlink-app/pom.xml

@@ -28,12 +28,12 @@
             <version>${flink.version}</version>
             <scope>provided</scope>
         </dependency>-->
-        <dependency>
+        <!--<dependency>
             <groupId>org.apache.flink</groupId>
             <artifactId>flink-java</artifactId>
             <version>${flink.version}</version>
             <scope>provided</scope>
-        </dependency>
+        </dependency>-->
         <!--<dependency>
             <groupId>org.apache.flink</groupId>
             <artifactId>flink-clients_${scala.binary.version}</artifactId>

dlink-executor/src/main/java/com/dlink/executor/ExecutorSetting.java

@@ -2,8 +2,6 @@ package com.dlink.executor;
 
 import com.dlink.assertion.Asserts;
 import com.fasterxml.jackson.core.JsonProcessingException;
-import com.fasterxml.jackson.core.type.TypeReference;
-import com.fasterxml.jackson.databind.JsonNode;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import lombok.Getter;
 import lombok.Setter;
@@ -22,6 +20,7 @@ import java.util.Map;
 @Setter
 @Getter
 public class ExecutorSetting {
+
     private Integer checkpoint;
     private Integer parallelism;
     private boolean useSqlFragment;
@@ -86,15 +85,17 @@ public class ExecutorSetting {
     }
 
     public static ExecutorSetting build(Integer checkpoint, Integer parallelism, boolean useSqlFragment,boolean useStatementSet, String savePointPath, String jobName, String configJson){
-        JsonNode paras = null;
-        Map<String,String> config = new HashMap<>();
+        List<Map<String,String>> configList = new ArrayList<>();
         if(Asserts.isNotNullString(configJson)) {
             try {
-                paras = mapper.readTree(configJson);
+                configList = mapper.readValue(configJson, ArrayList.class);
             } catch (JsonProcessingException e) {
                 e.printStackTrace();
             }
-            config = mapper.convertValue(paras, new TypeReference<Map<String, String>>(){});
+        }
+        Map<String,String> config = new HashMap<>();
+        for(Map<String,String> item : configList){
+            config.put(item.get("key"),item.get("value"));
         }
         return new ExecutorSetting(checkpoint,parallelism,useSqlFragment,useStatementSet,savePointPath,jobName,config);
     }

dlink-web/src/pages/Welcome.tsx

@@ -484,6 +484,15 @@ export default (): React.ReactNode => {
                 <li>
                   <Link>新增数据源的 Sql 作业语句执行</Link>
                 </li>
+                <li>
+                  <Link>优化 ClickHouse SQL 校验逻辑</Link>
+                </li>
+                <li>
+                  <Link>建立官网文档</Link>
+                </li>
+                <li>
+                  <Link>解决 Yarn Application 解析数组异常问题</Link>
+                </li>
               </ul>
             </Paragraph>
           </Timeline.Item>