fix: 集群模式抽取数据

backend/src/main/java/io/dataease/service/dataset/ExtractDataService.java

@@ -876,7 +876,12 @@ public class ExtractDataService {
             case StarRocks:
                 MysqlConfiguration mysqlConfiguration = new Gson().fromJson(datasource.getConfiguration(), MysqlConfiguration.class);
                 dataMeta = new DatabaseMeta("db", "MYSQL", "Native", mysqlConfiguration.getHost().trim(), mysqlConfiguration.getDataBase().trim(), mysqlConfiguration.getPort().toString(), mysqlConfiguration.getUsername(), mysqlConfiguration.getPassword());
-                dataMeta.addExtraOption("MYSQL", "characterEncoding", "UTF-8");
+                if(StringUtils.isNotEmpty(mysqlConfiguration.getExtraParams()) && mysqlConfiguration.getExtraParams().split("&").length > 0){
+                    String[] params = mysqlConfiguration.getExtraParams().split("&");
+                    for(int i=0;i<params.length;i++){
+                        dataMeta.addExtraOption("MYSQL", params[i].split("=")[0], params[i].split("=")[1]);
+                    }
+                }
                 transMeta.addDatabase(dataMeta);
                 selectSQL = getSelectSQL(extractType, datasetTable, datasource, datasetTableFields, selectSQL);
                 inputStep = inputStep(transMeta, selectSQL);

backend/src/main/java/io/dataease/service/kettle/KettleService.java

@@ -67,8 +67,7 @@ public class KettleService {
         httpClientConfig.addHeader("Authorization", authValue);
         try {
             String response = HttpClientUtil.get("http://" + kettleDTO.getCarte() + ":" + kettleDTO.getPort() + "/kettle/status/", httpClientConfig);
-
-            return ResultHolder.error("Kettle is valid.");
+            return ResultHolder.success("Kettle is valid.");
         }catch (Exception e){
             return ResultHolder.error("Kettle is invalid: " + e.getMessage());
         }