Support seatunnel 2.3.2 (#607)

LiuBodong · web-flow · commit 4a9d5e9da165 · 2023-08-22T20:28:32.000+08:00
* [Feature][Seatunnel] StarRocks add base-url property

* [Feature][setunnel-plugin-seatunnel-connector] Update starrocks plugin to 2.3.2

* [Feature][setunnel-plugin-seatunnel-connector] Change file system connector property 'file_format' to 'file_format_type'

* [Bugfix][Seatunnel] Seatunnel pulsar connector property type error.
diff --git a/scaleph-datasource/src/main/java/cn/sliew/scaleph/ds/modal/olap/StarRocksDataSource.java b/scaleph-datasource/src/main/java/cn/sliew/scaleph/ds/modal/olap/StarRocksDataSource.java
@@ -41,6 +41,10 @@ public class StarRocksDataSource extends AbstractDataSource {
     @Schema(description = "Node Urls")
     private String nodeUrls;
 
+    @NotBlank
+    @Schema(description = "Base url")
+    private String baseUrl;
+
     @NotBlank
     @Schema(description = "username")
     private String username;
diff --git a/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/file/FileSinkProperties.java b/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/file/FileSinkProperties.java
@@ -45,8 +45,8 @@ public enum FileSinkProperties {
             .addValidator(Validators.NON_BLANK_VALIDATOR)
             .validateAndBuild();
 
-    public static final PropertyDescriptor<String> FILE_FORMAT = new PropertyDescriptor.Builder<String>()
-            .name("file_format")
+    public static final PropertyDescriptor<String> FILE_FORMAT_TYPE = new PropertyDescriptor.Builder<String>()
+            .name("file_format_type")
             .description("We supported as the following file types:text, csv, excel, parquet, orc, json")
             .type(PropertyType.STRING)
             .defaultValue("text")
diff --git a/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/file/ftp/sink/FtpFileSinkPlugin.java b/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/file/ftp/sink/FtpFileSinkPlugin.java
@@ -50,7 +50,7 @@ public FtpFileSinkPlugin() {
 
         final List<PropertyDescriptor> props = new ArrayList<>();
         props.add(PATH);
-        props.add(FILE_FORMAT);
+        props.add(FILE_FORMAT_TYPE);
         props.add(CUSTOM_FILENAME);
         props.add(FILE_NAME_EXPRESSION);
         props.add(FILENAME_TIME_FORMAT);
diff --git a/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/file/hdfs/sink/HDFSFileSinkPlugin.java b/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/file/hdfs/sink/HDFSFileSinkPlugin.java
@@ -52,7 +52,7 @@ public HDFSFileSinkPlugin() {
 
         final List<PropertyDescriptor> props = new ArrayList<>();
         props.add(PATH);
-        props.add(FILE_FORMAT);
+        props.add(FILE_FORMAT_TYPE);
         props.add(CUSTOM_FILENAME);
         props.add(FILE_NAME_EXPRESSION);
         props.add(FILENAME_TIME_FORMAT);
diff --git a/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/file/local/sink/LocalFileSinkPlugin.java b/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/file/local/sink/LocalFileSinkPlugin.java
@@ -43,7 +43,7 @@ public LocalFileSinkPlugin() {
 
         final List<PropertyDescriptor> props = new ArrayList<>();
         props.add(PATH);
-        props.add(FILE_FORMAT);
+        props.add(FILE_FORMAT_TYPE);
         props.add(CUSTOM_FILENAME);
         props.add(FILE_NAME_EXPRESSION);
         props.add(FILENAME_TIME_FORMAT);
diff --git a/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/file/oss/sink/OSSSinkPlugin.java b/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/file/oss/sink/OSSSinkPlugin.java
@@ -50,7 +50,7 @@ public OSSSinkPlugin() {
 
         final List<PropertyDescriptor> props = new ArrayList<>();
         props.add(PATH);
-        props.add(FILE_FORMAT);
+        props.add(FILE_FORMAT_TYPE);
         props.add(CUSTOM_FILENAME);
         props.add(FILE_NAME_EXPRESSION);
         props.add(FILENAME_TIME_FORMAT);
diff --git a/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/file/ossjindo/sink/OSSJindoSinkPlugin.java b/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/file/ossjindo/sink/OSSJindoSinkPlugin.java
@@ -50,7 +50,7 @@ public OSSJindoSinkPlugin() {
 
         final List<PropertyDescriptor> props = new ArrayList<>();
         props.add(PATH);
-        props.add(FILE_FORMAT);
+        props.add(FILE_FORMAT_TYPE);
         props.add(CUSTOM_FILENAME);
         props.add(FILE_NAME_EXPRESSION);
         props.add(FILENAME_TIME_FORMAT);
diff --git a/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/file/s3/sink/S3SinkPlugin.java b/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/file/s3/sink/S3SinkPlugin.java
@@ -51,7 +51,7 @@ public S3SinkPlugin() {
         final List<PropertyDescriptor> props = new ArrayList<>();
         props.add(HADOOP_S3_PROPERTIES);
         props.add(PATH);
-        props.add(FILE_FORMAT);
+        props.add(FILE_FORMAT_TYPE);
         props.add(CUSTOM_FILENAME);
         props.add(FILE_NAME_EXPRESSION);
         props.add(FILENAME_TIME_FORMAT);
diff --git a/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/file/sftp/sink/SftpFileSinkPlugin.java b/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/file/sftp/sink/SftpFileSinkPlugin.java
@@ -50,7 +50,7 @@ public SftpFileSinkPlugin() {
 
         final List<PropertyDescriptor> props = new ArrayList<>();
         props.add(PATH);
-        props.add(FILE_FORMAT);
+        props.add(FILE_FORMAT_TYPE);
         props.add(CUSTOM_FILENAME);
         props.add(FILE_NAME_EXPRESSION);
         props.add(FILENAME_TIME_FORMAT);
diff --git a/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/pulsar/source/PulsarSourceProperties.java b/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/pulsar/source/PulsarSourceProperties.java
@@ -149,8 +149,8 @@ public enum PulsarSourceProperties {
     public static final PropertyDescriptor<String> CURSOR_STOP_TIMESTAMP = new PropertyDescriptor.Builder()
             .name("cursor.stop.timestamp")
             .description("Stop from the specified epoch timestamp (in milliseconds).")
-            .type(PropertyType.STRING)
-            .parser(Parsers.STRING_PARSER)
+            .type(PropertyType.LONG)
+            .parser(Parsers.LONG_PARSER)
             .addValidator(Validators.NON_BLANK_VALIDATOR)
             .validateAndBuild();
 
diff --git a/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/s3redshift/sink/S3RedshiftSinkPlugin.java b/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/s3redshift/sink/S3RedshiftSinkPlugin.java
@@ -56,7 +56,7 @@ public S3RedshiftSinkPlugin() {
 
         props.add(HADOOP_S3_PROPERTIES);
         props.add(PATH);
-        props.add(FILE_FORMAT);
+        props.add(FILE_FORMAT_TYPE);
         props.add(FILE_NAME_EXPRESSION);
         props.add(FILENAME_TIME_FORMAT);
         props.add(FIELD_DELIMITER);
diff --git a/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/starrocks/sink/StarRocksSinkPlugin.java b/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/starrocks/sink/StarRocksSinkPlugin.java
@@ -47,6 +47,7 @@ public StarRocksSinkPlugin() {
                 "Used to send data to StarRocks. Both support streaming and batch mode. The internal implementation of StarRocks sink connector is cached and imported by stream load in batches.",
                 StarRocksSinkPlugin.class.getName());
         final List<PropertyDescriptor> props = new ArrayList<>();
+        props.add(BASE_URL);
         props.add(DATABASE);
         props.add(TABLE);
         props.add(LABEL_PREFIX);
@@ -81,6 +82,9 @@ public ObjectNode createConf() {
         if (StringUtils.hasText(dataSource.getPassword())) {
             conf.putPOJO(PASSWORD.getName(), dataSource.getPassword());
         }
+        if (StringUtils.hasText(dataSource.getBaseUrl())) {
+            conf.putPOJO(BASE_URL.getName(), dataSource.getBaseUrl());
+        }
         return conf;
     }
 
diff --git a/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/starrocks/sink/StarRocksSinkProperties.java b/scaleph-plugins/scaleph-plugin-seatunnel-connectors/src/main/java/cn/sliew/scaleph/plugin/seatunnel/flink/connectors/starrocks/sink/StarRocksSinkProperties.java
@@ -18,15 +18,21 @@
 
 package cn.sliew.scaleph.plugin.seatunnel.flink.connectors.starrocks.sink;
 
-import cn.sliew.scaleph.plugin.framework.property.Parsers;
-import cn.sliew.scaleph.plugin.framework.property.PropertyDescriptor;
-import cn.sliew.scaleph.plugin.framework.property.PropertyType;
-import cn.sliew.scaleph.plugin.framework.property.Validators;
+import cn.sliew.scaleph.plugin.framework.property.*;
 import com.fasterxml.jackson.databind.JsonNode;
 
 public enum StarRocksSinkProperties {
     ;
 
+    public static final PropertyDescriptor<String> BASE_URL = new PropertyDescriptor.Builder<>()
+            .name("base-url")
+            .description("The JDBC URL like jdbc:mysql://localhost:9030/ or jdbc:mysql://localhost:9030 or jdbc:mysql://localhost:9030/db")
+            .properties(Property.Required)
+            .type(PropertyType.STRING)
+            .parser(Parsers.STRING_PARSER)
+            .addValidator(Validators.NON_BLANK_VALIDATOR)
+            .validateAndBuild();
+
     public static final PropertyDescriptor<String> LABEL_PREFIX = new PropertyDescriptor.Builder()
             .name("labelPrefix")
             .description("The prefix of StarRocks stream load label")
diff --git a/scaleph-ui-react/src/locales/zh-CN/pages/project.ts b/scaleph-ui-react/src/locales/zh-CN/pages/project.ts
@@ -570,6 +570,7 @@ export default {
 
 
   // starrocks
+  'pages.project.di.step.starrocks.base-url': '基础连接地址',
   'pages.project.di.step.starrocks.database': '数据库',
   'pages.project.di.step.starrocks.table': '数据表',
   'pages.project.di.step.starrocks.labelPrefix': '标签前缀',
@@ -616,7 +617,7 @@ export default {
 
   // s3redshift
   'pages.project.di.step.s3redshift.jdbcUrl': 'Jdbc URL',
-  'pages.project.di.step.s3redshift.jdbcUser': 'Jdbc哟你见过户',
+  'pages.project.di.step.s3redshift.jdbcUser': 'Jdbc用户名',
   'pages.project.di.step.s3redshift.jdbcPassword': 'Jdbc密码',
   'pages.project.di.step.s3redshift.executeSql': 'SQL查询语句',
   'pages.project.di.step.s3redshift.executeSql.placeholoder':
diff --git a/scaleph-ui-react/src/pages/Project/Workspace/Artifact/DI/DiJobFlow/Dag/constant.tsx b/scaleph-ui-react/src/pages/Project/Workspace/Artifact/DI/DiJobFlow/Dag/constant.tsx
@@ -160,7 +160,6 @@ export const BaseFileParams = {
   dateFormat: 'date_format',
   timeFormat: 'time_format',
   datetimeFormat: 'datetime_format',
-  fileFormat: 'file_format',
   customFilename: 'custom_filename',
   fileNameExpression: 'file_name_expression',
   filenameTimeFormat: 'filename_time_format',
@@ -519,6 +518,7 @@ export const DorisParams = {
 };
 
 export const StarRocksParams = {
+  baseUrl: 'base-url',
   database: 'database',
   table: 'table',
   labelPrefix: 'labelPrefix',
diff --git a/scaleph-ui-react/src/pages/Project/Workspace/Artifact/DI/DiJobFlow/Dag/steps/sink/sink-ftp-file-step.tsx b/scaleph-ui-react/src/pages/Project/Workspace/Artifact/DI/DiJobFlow/Dag/steps/sink/sink-ftp-file-step.tsx
@@ -80,14 +80,14 @@ const SinkFtpFileStepForm: React.FC<
           colProps={{span: 24}}
         />
         <ProFormSelect
-          name={'file_format'}
+          name={BaseFileParams.fileFormatType}
           label={intl.formatMessage({id: 'pages.project.di.step.baseFile.fileFormat'})}
           colProps={{span: 24}}
           options={['json', 'parquet', 'orc', 'text', 'csv', 'excel']}
         />
-        <ProFormDependency name={['file_format']}>
-          {({file_format}) => {
-            if (file_format == 'text' || file_format == 'csv') {
+        <ProFormDependency name={[BaseFileParams.fileFormatType]}>
+          {({file_format_type}) => {
+            if (file_format_type == 'text' || file_format_type == 'csv') {
               return (
                 <ProFormGroup>
                   <ProFormText
@@ -109,7 +109,7 @@ const SinkFtpFileStepForm: React.FC<
                 </ProFormGroup>
               );
             }
-            if (file_format == 'excel') {
+            if (file_format_type == 'excel') {
               return (
                 <ProFormGroup>
                   <ProFormText
diff --git a/scaleph-ui-react/src/pages/Project/Workspace/Artifact/DI/DiJobFlow/Dag/steps/sink/sink-hdfs-file-step.tsx b/scaleph-ui-react/src/pages/Project/Workspace/Artifact/DI/DiJobFlow/Dag/steps/sink/sink-hdfs-file-step.tsx
@@ -78,13 +78,13 @@ const SinkHdfsFileStepForm: React.FC<
           rules={[{required: true}]}
         />
         <ProFormSelect
-          name={'file_format'}
+          name={BaseFileParams.fileFormatType}
           label={intl.formatMessage({id: 'pages.project.di.step.baseFile.fileFormat'})}
           options={['json', 'parquet', 'orc', 'text', 'csv', 'excel']}
         />
-        <ProFormDependency name={['file_format']}>
-          {({file_format}) => {
-            if (file_format == 'text' || file_format == 'csv') {
+        <ProFormDependency name={[BaseFileParams.fileFormatType]}>
+          {({file_format_type}) => {
+            if (file_format_type == 'text' || file_format_type == 'csv') {
               return (
                 <ProFormGroup>
                   <ProFormText
@@ -106,7 +106,7 @@ const SinkHdfsFileStepForm: React.FC<
                 </ProFormGroup>
               );
             }
-            if (file_format == 'excel') {
+            if (file_format_type == 'excel') {
               return (
                 <ProFormGroup>
                   <ProFormText
diff --git a/scaleph-ui-react/src/pages/Project/Workspace/Artifact/DI/DiJobFlow/Dag/steps/sink/sink-local-file-step.tsx b/scaleph-ui-react/src/pages/Project/Workspace/Artifact/DI/DiJobFlow/Dag/steps/sink/sink-local-file-step.tsx
@@ -78,14 +78,14 @@ const SinkLocalFileStepForm: React.FC<
           colProps={{span: 24}}
         />
         <ProFormSelect
-          name={'file_format'}
+          name={BaseFileParams.fileFormatType}
           label={intl.formatMessage({id: 'pages.project.di.step.baseFile.fileFormat'})}
           colProps={{span: 24}}
           options={['json', 'parquet', 'orc', 'text', 'csv', 'excel']}
         />
-        <ProFormDependency name={['file_format']}>
-          {({file_format}) => {
-            if (file_format == 'text' || file_format == 'csv') {
+        <ProFormDependency name={[BaseFileParams.fileFormatType]}>
+          {({file_format_type}) => {
+            if (file_format_type == 'text' || file_format_type == 'csv') {
               return (
                 <ProFormGroup>
                   <ProFormText
@@ -107,7 +107,7 @@ const SinkLocalFileStepForm: React.FC<
                 </ProFormGroup>
               );
             }
-            if (file_format == 'excel') {
+            if (file_format_type == 'excel') {
               return (
                 <ProFormGroup>
                   <ProFormText
diff --git a/scaleph-ui-react/src/pages/Project/Workspace/Artifact/DI/DiJobFlow/Dag/steps/sink/sink-oss-file-step.tsx b/scaleph-ui-react/src/pages/Project/Workspace/Artifact/DI/DiJobFlow/Dag/steps/sink/sink-oss-file-step.tsx
@@ -80,14 +80,14 @@ const SinkOSSFileStepForm: React.FC<
           colProps={{span: 24}}
         />
         <ProFormSelect
-          name={'file_format'}
+          name={BaseFileParams.fileFormatType}
           label={intl.formatMessage({id: 'pages.project.di.step.baseFile.fileFormat'})}
           colProps={{span: 24}}
           options={['json', 'parquet', 'orc', 'text', 'csv', 'excel']}
         />
-        <ProFormDependency name={['file_format']}>
-          {({file_format}) => {
-            if (file_format == 'text' || file_format == 'csv') {
+        <ProFormDependency name={[BaseFileParams.fileFormatType]}>
+          {({file_format_type}) => {
+            if (file_format_type == 'text' || file_format_type == 'csv') {
               return (
                 <ProFormGroup>
                   <ProFormText
@@ -109,7 +109,7 @@ const SinkOSSFileStepForm: React.FC<
                 </ProFormGroup>
               );
             }
-            if (file_format == 'excel') {
+            if (file_format_type == 'excel') {
               return (
                 <ProFormGroup>
                   <ProFormText
diff --git a/scaleph-ui-react/src/pages/Project/Workspace/Artifact/DI/DiJobFlow/Dag/steps/sink/sink-ossjindo-file-step.tsx b/scaleph-ui-react/src/pages/Project/Workspace/Artifact/DI/DiJobFlow/Dag/steps/sink/sink-ossjindo-file-step.tsx
@@ -80,14 +80,14 @@ const SinkOSSJindoFileStepForm: React.FC<
           colProps={{span: 24}}
         />
         <ProFormSelect
-          name={'file_format'}
+          name={BaseFileParams.fileFormatType}
           label={intl.formatMessage({id: 'pages.project.di.step.baseFile.fileFormat'})}
           colProps={{span: 24}}
           options={['json', 'parquet', 'orc', 'text', 'csv', 'excel']}
         />
-        <ProFormDependency name={['file_format']}>
-          {({file_format}) => {
-            if (file_format == 'text' || file_format == 'csv') {
+        <ProFormDependency name={[BaseFileParams.fileFormatType]}>
+          {({file_format_type}) => {
+            if (file_format_type == 'text' || file_format_type == 'csv') {
               return (
                 <ProFormGroup>
                   <ProFormText
@@ -109,7 +109,7 @@ const SinkOSSJindoFileStepForm: React.FC<
                 </ProFormGroup>
               );
             }
-            if (file_format == 'excel') {
+            if (file_format_type == 'excel') {
               return (
                 <ProFormGroup>
                   <ProFormText
diff --git a/scaleph-ui-react/src/pages/Project/Workspace/Artifact/DI/DiJobFlow/Dag/steps/sink/sink-s3-file-step.tsx b/scaleph-ui-react/src/pages/Project/Workspace/Artifact/DI/DiJobFlow/Dag/steps/sink/sink-s3-file-step.tsx
@@ -127,14 +127,14 @@ const SinkS3FileStepForm: React.FC<
           colProps={{span: 24}}
         />
         <ProFormSelect
-          name={'file_format'}
+          name={BaseFileParams.fileFormatType}
           label={intl.formatMessage({id: 'pages.project.di.step.baseFile.fileFormat'})}
           colProps={{span: 24}}
           options={['json', 'parquet', 'orc', 'text', 'csv', 'excel']}
         />
-        <ProFormDependency name={['file_format']}>
-          {({file_format}) => {
-            if (file_format == 'text' || file_format == 'csv') {
+        <ProFormDependency name={[BaseFileParams.fileFormatType]}>
+          {({file_format_type}) => {
+            if (file_format_type == 'text' || file_format_type == 'csv') {
               return (
                 <ProFormGroup>
                   <ProFormText
@@ -156,7 +156,7 @@ const SinkS3FileStepForm: React.FC<
                 </ProFormGroup>
               );
             }
-            if (file_format == 'excel') {
+            if (file_format_type == 'excel') {
               return (
                 <ProFormGroup>
                   <ProFormText
diff --git a/scaleph-ui-react/src/pages/Project/Workspace/Artifact/DI/DiJobFlow/Dag/steps/sink/sink-s3redshift-file-step.tsx b/scaleph-ui-react/src/pages/Project/Workspace/Artifact/DI/DiJobFlow/Dag/steps/sink/sink-s3redshift-file-step.tsx
@@ -134,7 +134,7 @@ const SinkS3RedshiftStepForm: React.FC<ModalFormProps<{
           colProps={{span: 24}}
         />
         <ProFormSelect
-          name={'file_format'}
+          name={BaseFileParams.fileFormatType}
           label={intl.formatMessage({id: 'pages.project.di.step.baseFile.fileFormat'})}
           colProps={{span: 24}}
           valueEnum={{
@@ -145,9 +145,9 @@ const SinkS3RedshiftStepForm: React.FC<ModalFormProps<{
             csv: 'csv',
           }}
         />
-        <ProFormDependency name={['file_format']}>
-          {({file_format}) => {
-            if (file_format == 'text' || file_format == 'csv') {
+        <ProFormDependency name={[BaseFileParams.fileFormatType]}>
+          {({file_format_type}) => {
+            if (file_format_type == 'text' || file_format_type == 'csv') {
               return (
                 <ProFormGroup>
                   <ProFormText
diff --git a/scaleph-ui-react/src/pages/Project/Workspace/Artifact/DI/DiJobFlow/Dag/steps/sink/sink-sftp-file-step.tsx b/scaleph-ui-react/src/pages/Project/Workspace/Artifact/DI/DiJobFlow/Dag/steps/sink/sink-sftp-file-step.tsx
@@ -78,14 +78,14 @@ const SinkSftpFileStepForm: React.FC<ModalFormProps<{
           colProps={{span: 24}}
         />
         <ProFormSelect
-          name={'file_format'}
+          name={BaseFileParams.fileFormatType}
           label={intl.formatMessage({id: 'pages.project.di.step.baseFile.fileFormat'})}
           colProps={{span: 24}}
           options={['json', 'parquet', 'orc', 'text', 'csv', 'excel']}
         />
-        <ProFormDependency name={['file_format']}>
-          {({file_format}) => {
-            if (file_format == 'text' || file_format == 'csv') {
+        <ProFormDependency name={[BaseFileParams.fileFormatType]}>
+          {({file_format_type}) => {
+            if (file_format_type == 'text' || file_format_type == 'csv') {
               return (
                 <ProFormGroup>
                   <ProFormText
@@ -107,7 +107,7 @@ const SinkSftpFileStepForm: React.FC<ModalFormProps<{
                 </ProFormGroup>
               );
             }
-            if (file_format == 'excel') {
+            if (file_format_type == 'excel') {
               return (
                 <ProFormGroup>
                   <ProFormText
diff --git a/scaleph-ui-react/src/pages/Project/Workspace/Artifact/DI/DiJobFlow/Dag/steps/sink/sink-starrocks-step.tsx b/scaleph-ui-react/src/pages/Project/Workspace/Artifact/DI/DiJobFlow/Dag/steps/sink/sink-starrocks-step.tsx
