fix: remove writeFormat from doris perTable

Author: jarad0628

connectors/doris-connector/src/main/java/io/tapdata/connector/doris/bean/DorisConfig.java

@@ -24,7 +24,7 @@ public class DorisConfig extends CommonDbConfig {
     private List<LinkedHashMap<String, String>> tableProperties = new ArrayList<>();
     private Boolean jdbcCompletion = false;
 
-    private Boolean useHTTPS =false;
+    private Boolean useHTTPS = false;
 
     private Integer backendNum;
 
@@ -38,9 +38,9 @@ public DorisConfig() {
     public DorisConfig load(Map<String, Object> map) {
         DorisConfig config = (DorisConfig) super.load(map);
         config.setSchema(config.getDatabase());
-        if(Boolean.TRUE.equals(useHTTPS)){
+        if (Boolean.TRUE.equals(useHTTPS)) {
             config.setDorisHttp(getDorisHttp().replace("https://", ""));
-        }else{
+        } else {
             config.setDorisHttp(getDorisHttp().replace("http://", ""));
         }
         return config;
@@ -109,10 +109,6 @@ public String getWriteFormat() {
         return writeFormat;
     }
 
-    public String getWriteFormat(String key) {
-        return getTableConfigValue(key, "writeFormat", writeFormat);
-    }
-
     public void setWriteFormat(String writeFormat) {
         this.writeFormat = writeFormat;
     }
@@ -185,8 +181,4 @@ public enum WriteFormat {
     public WriteFormat getWriteFormatEnum() {
         return WriteFormat.valueOf(writeFormat);
     }
-
-    public WriteFormat getWriteFormatEnum(String key) {
-        return WriteFormat.valueOf(getTableConfigValue(key, "writeFormat", writeFormat));
-    }
 }

connectors/doris-connector/src/main/java/io/tapdata/connector/doris/streamload/DorisStreamLoader.java

@@ -71,7 +71,7 @@ public DorisStreamLoader(DorisJdbcContext dorisJdbcContext, CloseableHttpClient
     }
 
     private void initMessageSerializer() {
-        DorisConfig.WriteFormat writeFormat = dorisConfig.getWriteFormatEnum(tapTable.getId());
+        DorisConfig.WriteFormat writeFormat = dorisConfig.getWriteFormatEnum();
         TapLogger.info(TAG, "Doris stream load run with {} format", writeFormat);
         switch (writeFormat) {
             case csv:
@@ -137,7 +137,7 @@ private Set<String> getDataColumns(TapRecordEvent recordEvent) {
     }
 
     public RespContent put(final TapTable table) throws StreamLoadException, DorisRetryableException {
-        DorisConfig.WriteFormat writeFormat = dorisConfig.getWriteFormatEnum(table.getId());
+        DorisConfig.WriteFormat writeFormat = dorisConfig.getWriteFormatEnum();
         try {
             final String loadUrl = buildLoadUrl(dorisConfig.getDorisHttp(), dorisConfig.getDatabase(), table.getId());
             final String prefix = buildPrefix(URLEncoder.encode(table.getId()).replace("%", ""));

connectors/doris-connector/src/main/resources/spec_doris.json

@@ -487,7 +487,6 @@
           "title": "${writeFormat}",
           "default": "json",
           "x-index": 7,
-          "x-perTable": true,
           "x-decorator": "FormItem",
           "x-decorator-props": {
             "feedbackLayout": "none"