[improve] milvus options (#9165)

liunaijie · web-flow · commit 5247e176409c · 2025-04-14T10:11:40.000+08:00
diff --git a/seatunnel-ci-tools/src/test/java/org/apache/seatunnel/api/ConnectorOptionCheckTest.java b/seatunnel-ci-tools/src/test/java/org/apache/seatunnel/api/ConnectorOptionCheckTest.java
@@ -204,13 +204,11 @@ private Set<String> buildWhiteList() {
         whiteList.add("SlsSourceOptions");
         whiteList.add("SentrySinkOptions");
         whiteList.add("QdrantSinkOptions");
-        whiteList.add("MilvusSourceOptions");
         whiteList.add("RocketMqSinkOptions");
         whiteList.add("MaxcomputeSourceOptions");
         whiteList.add("KuduSourceOptions");
         whiteList.add("SocketSinkOptions");
         whiteList.add("SelectDBSinkOptions");
-        whiteList.add("MilvusSinkOptions");
         whiteList.add("RocketMqSourceOptions");
         whiteList.add("TablestoreSinkOptions");
         whiteList.add("TableStoreDBSourceOptions");
diff --git a/seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/catalog/MilvusCatalog.java b/seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/catalog/MilvusCatalog.java
@@ -33,7 +33,7 @@
 import org.apache.seatunnel.api.table.catalog.exception.TableAlreadyExistException;
 import org.apache.seatunnel.api.table.catalog.exception.TableNotExistException;
 import org.apache.seatunnel.api.table.type.CommonOptions;
-import org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSinkConfig;
+import org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSinkOptions;
 import org.apache.seatunnel.connectors.seatunnel.milvus.exception.MilvusConnectionErrorCode;
 import org.apache.seatunnel.connectors.seatunnel.milvus.exception.MilvusConnectorException;
 import org.apache.seatunnel.connectors.seatunnel.milvus.utils.sink.MilvusSinkConverter;
@@ -71,7 +71,7 @@
 import java.util.Objects;
 import java.util.Optional;
 
-import static org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSinkConfig.CREATE_INDEX;
+import static org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSinkOptions.CREATE_INDEX;
 import static org.apache.seatunnel.shade.com.google.common.base.Preconditions.checkNotNull;
 
 @Slf4j
@@ -91,8 +91,8 @@ public MilvusCatalog(String catalogName, ReadonlyConfig config) {
     public void open() throws CatalogException {
         ConnectParam connectParam =
                 ConnectParam.newBuilder()
-                        .withUri(config.get(MilvusSinkConfig.URL))
-                        .withToken(config.get(MilvusSinkConfig.TOKEN))
+                        .withUri(config.get(MilvusSinkOptions.URL))
+                        .withToken(config.get(MilvusSinkOptions.TOKEN))
                         .build();
         try {
             this.client = new MilvusServiceClient(connectParam);
@@ -242,9 +242,9 @@ public void createTableInternal(TablePath tablePath, CatalogTable catalogTable)
             String partitionKeyField =
                     existPartitionKeyField ? options.get(MilvusOptions.PARTITION_KEY_FIELD) : null;
             // if options set, will overwrite aut read
-            if (StringUtils.isNotEmpty(config.get(MilvusSinkConfig.PARTITION_KEY))) {
+            if (StringUtils.isNotEmpty(config.get(MilvusSinkOptions.PARTITION_KEY))) {
                 existPartitionKeyField = true;
-                partitionKeyField = config.get(MilvusSinkConfig.PARTITION_KEY);
+                partitionKeyField = config.get(MilvusSinkOptions.PARTITION_KEY);
             }
 
             TableSchema tableSchema = catalogTable.getTableSchema();
@@ -261,21 +261,21 @@ public void createTableInternal(TablePath tablePath, CatalogTable catalogTable)
                                 column,
                                 tableSchema.getPrimaryKey(),
                                 partitionKeyField,
-                                config.get(MilvusSinkConfig.ENABLE_AUTO_ID));
+                                config.get(MilvusSinkOptions.ENABLE_AUTO_ID));
                 fieldTypes.add(fieldType);
             }
 
             Boolean enableDynamicField =
                     (options.containsKey(MilvusOptions.ENABLE_DYNAMIC_FIELD))
                             ? Boolean.valueOf(options.get(MilvusOptions.ENABLE_DYNAMIC_FIELD))
-                            : config.get(MilvusSinkConfig.ENABLE_DYNAMIC_FIELD);
+                            : config.get(MilvusSinkOptions.ENABLE_DYNAMIC_FIELD);
             String collectionDescription = "";
-            if (config.get(MilvusSinkConfig.COLLECTION_DESCRIPTION) != null
-                    && config.get(MilvusSinkConfig.COLLECTION_DESCRIPTION)
+            if (config.get(MilvusSinkOptions.COLLECTION_DESCRIPTION) != null
+                    && config.get(MilvusSinkOptions.COLLECTION_DESCRIPTION)
                             .containsKey(tablePath.getTableName())) {
                 // use description from config first
                 collectionDescription =
-                        config.get(MilvusSinkConfig.COLLECTION_DESCRIPTION)
+                        config.get(MilvusSinkOptions.COLLECTION_DESCRIPTION)
                                 .get(tablePath.getTableName());
             } else if (null != catalogTable.getComment()) {
                 collectionDescription = catalogTable.getComment();
diff --git a/seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/config/MilvusBaseOptions.java b/seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/config/MilvusBaseOptions.java
@@ -20,7 +20,7 @@
 import org.apache.seatunnel.api.configuration.Option;
 import org.apache.seatunnel.api.configuration.Options;
 
-public abstract class MilvusCommonConfig {
+public abstract class MilvusBaseOptions {
 
     public static final String CONNECTOR_IDENTITY = "Milvus";
 
diff --git a/seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/config/MilvusSinkOptions.java b/seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/config/MilvusSinkOptions.java
@@ -30,7 +30,7 @@
 import static org.apache.seatunnel.api.sink.DataSaveMode.DROP_DATA;
 import static org.apache.seatunnel.api.sink.DataSaveMode.ERROR_WHEN_DATA_EXISTS;
 
-public class MilvusSinkConfig extends MilvusCommonConfig {
+public class MilvusSinkOptions extends MilvusBaseOptions {
 
     public static final Option<String> DATABASE =
             Options.key("database").stringType().noDefaultValue().withDescription("database");
diff --git a/seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/config/MilvusSourceOptions.java b/seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/config/MilvusSourceOptions.java
@@ -20,7 +20,7 @@
 import org.apache.seatunnel.api.configuration.Option;
 import org.apache.seatunnel.api.configuration.Options;
 
-public class MilvusSourceConfig extends MilvusCommonConfig {
+public class MilvusSourceOptions extends MilvusBaseOptions {
 
     public static final Option<String> DATABASE =
             Options.key("database")
diff --git a/seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/sink/MilvusBufferBatchWriter.java b/seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/sink/MilvusBufferBatchWriter.java
@@ -53,14 +53,14 @@
 import java.util.Objects;
 import java.util.concurrent.atomic.AtomicLong;
 
-import static org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSinkConfig.BATCH_SIZE;
-import static org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSinkConfig.CREATE_INDEX;
-import static org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSinkConfig.ENABLE_AUTO_ID;
-import static org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSinkConfig.ENABLE_UPSERT;
-import static org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSinkConfig.LOAD_COLLECTION;
-import static org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSinkConfig.RATE_LIMIT;
-import static org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSinkConfig.TOKEN;
-import static org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSinkConfig.URL;
+import static org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSinkOptions.BATCH_SIZE;
+import static org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSinkOptions.CREATE_INDEX;
+import static org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSinkOptions.ENABLE_AUTO_ID;
+import static org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSinkOptions.ENABLE_UPSERT;
+import static org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSinkOptions.LOAD_COLLECTION;
+import static org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSinkOptions.RATE_LIMIT;
+import static org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSinkOptions.TOKEN;
+import static org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSinkOptions.URL;
 
 @Slf4j
 public class MilvusBufferBatchWriter {
diff --git a/seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/sink/MilvusSink.java b/seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/sink/MilvusSink.java
@@ -33,7 +33,7 @@
 import org.apache.seatunnel.api.table.factory.CatalogFactory;
 import org.apache.seatunnel.api.table.type.SeaTunnelRow;
 import org.apache.seatunnel.connectors.seatunnel.milvus.catalog.MilvusCatalogFactory;
-import org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSinkConfig;
+import org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSinkOptions;
 import org.apache.seatunnel.connectors.seatunnel.milvus.state.MilvusAggregatedCommitInfo;
 import org.apache.seatunnel.connectors.seatunnel.milvus.state.MilvusCommitInfo;
 import org.apache.seatunnel.connectors.seatunnel.milvus.state.MilvusSinkState;
@@ -90,7 +90,7 @@ public Optional<Serializer<MilvusCommitInfo>> getCommitInfoSerializer() {
 
     @Override
     public String getPluginName() {
-        return MilvusSinkConfig.CONNECTOR_IDENTITY;
+        return MilvusSinkOptions.CONNECTOR_IDENTITY;
     }
 
     @Override
@@ -102,8 +102,8 @@ public Optional<SaveModeHandler> getSaveModeHandler() {
         CatalogFactory catalogFactory = new MilvusCatalogFactory();
         Catalog catalog = catalogFactory.createCatalog(catalogTable.getCatalogName(), config);
 
-        SchemaSaveMode schemaSaveMode = config.get(MilvusSinkConfig.SCHEMA_SAVE_MODE);
-        DataSaveMode dataSaveMode = config.get(MilvusSinkConfig.DATA_SAVE_MODE);
+        SchemaSaveMode schemaSaveMode = config.get(MilvusSinkOptions.SCHEMA_SAVE_MODE);
+        DataSaveMode dataSaveMode = config.get(MilvusSinkOptions.DATA_SAVE_MODE);
 
         return Optional.of(
                 new DefaultSaveModeHandler(
diff --git a/seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/sink/MilvusSinkFactory.java b/seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/sink/MilvusSinkFactory.java
@@ -25,7 +25,7 @@
 import org.apache.seatunnel.api.table.factory.Factory;
 import org.apache.seatunnel.api.table.factory.TableSinkFactory;
 import org.apache.seatunnel.api.table.factory.TableSinkFactoryContext;
-import org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSinkConfig;
+import org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSinkOptions;
 
 import org.apache.commons.lang3.StringUtils;
 
@@ -42,13 +42,13 @@ public String factoryIdentifier() {
     @Override
     public OptionRule optionRule() {
         return OptionRule.builder()
-                .required(MilvusSinkConfig.URL, MilvusSinkConfig.TOKEN)
+                .required(MilvusSinkOptions.URL, MilvusSinkOptions.TOKEN)
                 .optional(
-                        MilvusSinkConfig.ENABLE_UPSERT,
-                        MilvusSinkConfig.ENABLE_DYNAMIC_FIELD,
-                        MilvusSinkConfig.ENABLE_AUTO_ID,
-                        MilvusSinkConfig.SCHEMA_SAVE_MODE,
-                        MilvusSinkConfig.DATA_SAVE_MODE)
+                        MilvusSinkOptions.ENABLE_UPSERT,
+                        MilvusSinkOptions.ENABLE_DYNAMIC_FIELD,
+                        MilvusSinkOptions.ENABLE_AUTO_ID,
+                        MilvusSinkOptions.SCHEMA_SAVE_MODE,
+                        MilvusSinkOptions.DATA_SAVE_MODE)
                 .build();
     }
 
@@ -62,8 +62,8 @@ private CatalogTable renameCatalogTable(
             ReadonlyConfig config, CatalogTable sourceCatalogTable) {
         TableIdentifier sourceTableId = sourceCatalogTable.getTableId();
         String databaseName;
-        if (StringUtils.isNotEmpty(config.get(MilvusSinkConfig.DATABASE))) {
-            databaseName = config.get(MilvusSinkConfig.DATABASE);
+        if (StringUtils.isNotEmpty(config.get(MilvusSinkOptions.DATABASE))) {
+            databaseName = config.get(MilvusSinkOptions.DATABASE);
         } else {
             databaseName = sourceTableId.getDatabaseName();
         }
diff --git a/seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/source/MilvusSource.java b/seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/source/MilvusSource.java
@@ -27,7 +27,7 @@
 import org.apache.seatunnel.api.table.catalog.CatalogTable;
 import org.apache.seatunnel.api.table.catalog.TablePath;
 import org.apache.seatunnel.api.table.type.SeaTunnelRow;
-import org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSourceConfig;
+import org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSourceOptions;
 import org.apache.seatunnel.connectors.seatunnel.milvus.utils.MilvusConvertUtils;
 
 import java.util.ArrayList;
@@ -79,6 +79,6 @@ public SourceSplitEnumerator<MilvusSourceSplit, MilvusSourceState> restoreEnumer
 
     @Override
     public String getPluginName() {
-        return MilvusSourceConfig.CONNECTOR_IDENTITY;
+        return MilvusSourceOptions.CONNECTOR_IDENTITY;
     }
 }
diff --git a/seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/source/MilvusSourceFactory.java b/seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/source/MilvusSourceFactory.java
@@ -24,7 +24,7 @@
 import org.apache.seatunnel.api.table.factory.Factory;
 import org.apache.seatunnel.api.table.factory.TableSourceFactory;
 import org.apache.seatunnel.api.table.factory.TableSourceFactoryContext;
-import org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSourceConfig;
+import org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSourceOptions;
 
 import com.google.auto.service.AutoService;
 import lombok.extern.slf4j.Slf4j;
@@ -44,8 +44,8 @@ TableSource<T, SplitT, StateT> createSource(TableSourceFactoryContext context) {
     @Override
     public OptionRule optionRule() {
         return OptionRule.builder()
-                .required(MilvusSourceConfig.URL, MilvusSourceConfig.TOKEN)
-                .optional(MilvusSourceConfig.DATABASE, MilvusSourceConfig.COLLECTION)
+                .required(MilvusSourceOptions.URL, MilvusSourceOptions.TOKEN)
+                .optional(MilvusSourceOptions.DATABASE, MilvusSourceOptions.COLLECTION)
                 .build();
     }
 
diff --git a/seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/source/MilvusSourceReader.java b/seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/source/MilvusSourceReader.java
@@ -26,7 +26,7 @@
 import org.apache.seatunnel.api.table.catalog.TableSchema;
 import org.apache.seatunnel.api.table.type.CommonOptions;
 import org.apache.seatunnel.api.table.type.SeaTunnelRow;
-import org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSourceConfig;
+import org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSourceOptions;
 import org.apache.seatunnel.connectors.seatunnel.milvus.exception.MilvusConnectionErrorCode;
 import org.apache.seatunnel.connectors.seatunnel.milvus.exception.MilvusConnectorException;
 import org.apache.seatunnel.connectors.seatunnel.milvus.utils.source.MilvusSourceConverter;
@@ -59,8 +59,8 @@
 import java.util.Map;
 import java.util.concurrent.ConcurrentLinkedDeque;
 
-import static org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSourceConfig.BATCH_SIZE;
-import static org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSourceConfig.RATE_LIMIT;
+import static org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSourceOptions.BATCH_SIZE;
+import static org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSourceOptions.RATE_LIMIT;
 
 @Slf4j
 public class MilvusSourceReader implements SourceReader<SeaTunnelRow, MilvusSourceSplit> {
@@ -88,8 +88,8 @@ public void open() throws Exception {
         client =
                 new MilvusServiceClient(
                         ConnectParam.newBuilder()
-                                .withUri(config.get(MilvusSourceConfig.URL))
-                                .withToken(config.get(MilvusSourceConfig.TOKEN))
+                                .withUri(config.get(MilvusSourceOptions.URL))
+                                .withToken(config.get(MilvusSourceOptions.TOKEN))
                                 .build());
         setRateLimit(config.get(RATE_LIMIT).toString());
     }
diff --git a/seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/source/MilvusSourceSplitEnumerator.java b/seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/source/MilvusSourceSplitEnumerator.java
@@ -22,7 +22,7 @@
 import org.apache.seatunnel.api.table.catalog.CatalogTable;
 import org.apache.seatunnel.api.table.catalog.TablePath;
 import org.apache.seatunnel.common.exception.CommonErrorCodeDeprecated;
-import org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSourceConfig;
+import org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSourceOptions;
 import org.apache.seatunnel.connectors.seatunnel.milvus.exception.MilvusConnectionErrorCode;
 import org.apache.seatunnel.connectors.seatunnel.milvus.exception.MilvusConnectorException;
 
@@ -81,8 +81,8 @@ public MilvusSourceSplitEnumerator(
     public void open() {
         ConnectParam connectParam =
                 ConnectParam.newBuilder()
-                        .withUri(config.get(MilvusSourceConfig.URL))
-                        .withToken(config.get(MilvusSourceConfig.TOKEN))
+                        .withUri(config.get(MilvusSourceOptions.URL))
+                        .withToken(config.get(MilvusSourceOptions.TOKEN))
                         .build();
         this.client = new MilvusServiceClient(connectParam);
     }
diff --git a/seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/utils/MilvusConvertUtils.java b/seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/utils/MilvusConvertUtils.java
@@ -29,7 +29,7 @@
 import org.apache.seatunnel.api.table.catalog.VectorIndex;
 import org.apache.seatunnel.api.table.type.CommonOptions;
 import org.apache.seatunnel.connectors.seatunnel.milvus.catalog.MilvusOptions;
-import org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSourceConfig;
+import org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSourceOptions;
 import org.apache.seatunnel.connectors.seatunnel.milvus.exception.MilvusConnectionErrorCode;
 import org.apache.seatunnel.connectors.seatunnel.milvus.exception.MilvusConnectorException;
 import org.apache.seatunnel.connectors.seatunnel.milvus.utils.source.MilvusSourceConverter;
@@ -77,14 +77,14 @@ public Map<TablePath, CatalogTable> getSourceTables() {
         MilvusServiceClient client =
                 new MilvusServiceClient(
                         ConnectParam.newBuilder()
-                                .withUri(config.get(MilvusSourceConfig.URL))
-                                .withToken(config.get(MilvusSourceConfig.TOKEN))
+                                .withUri(config.get(MilvusSourceOptions.URL))
+                                .withToken(config.get(MilvusSourceOptions.TOKEN))
                                 .build());
 
-        String database = config.get(MilvusSourceConfig.DATABASE);
+        String database = config.get(MilvusSourceOptions.DATABASE);
         List<String> collectionList = new ArrayList<>();
-        if (StringUtils.isNotEmpty(config.get(MilvusSourceConfig.COLLECTION))) {
-            collectionList.add(config.get(MilvusSourceConfig.COLLECTION));
+        if (StringUtils.isNotEmpty(config.get(MilvusSourceOptions.COLLECTION))) {
+            collectionList.add(config.get(MilvusSourceOptions.COLLECTION));
         } else {
             R<ShowCollectionsResponse> response =
                     client.showCollections(
diff --git a/seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/utils/sink/MilvusSinkConverter.java b/seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/utils/sink/MilvusSinkConverter.java
@@ -49,8 +49,8 @@
 import java.util.stream.Collectors;
 
 import static org.apache.seatunnel.api.table.catalog.PrimaryKey.isPrimaryKeyField;
-import static org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSinkConfig.ENABLE_AUTO_ID;
-import static org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSinkConfig.ENABLE_DYNAMIC_FIELD;
+import static org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSinkOptions.ENABLE_AUTO_ID;
+import static org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSinkOptions.ENABLE_DYNAMIC_FIELD;
 
 public class MilvusSinkConverter {
     private static final Gson gson = new Gson();
diff --git a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-milvus-e2e/src/test/java/org/apache/seatunnel/e2e/connector/v2/milvus/MilvusIT.java b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-milvus-e2e/src/test/java/org/apache/seatunnel/e2e/connector/v2/milvus/MilvusIT.java
@@ -32,7 +32,7 @@
 import org.apache.seatunnel.api.table.type.VectorType;
 import org.apache.seatunnel.common.utils.BufferUtils;
 import org.apache.seatunnel.connectors.seatunnel.milvus.catalog.MilvusCatalog;
-import org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSinkConfig;
+import org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSinkOptions;
 import org.apache.seatunnel.e2e.common.TestResource;
 import org.apache.seatunnel.e2e.common.TestSuiteBase;
 import org.apache.seatunnel.e2e.common.container.EngineType;
@@ -128,8 +128,8 @@ private void initMilvus()
             throws SQLException, ClassNotFoundException, InstantiationException,
                     IllegalAccessException {
         Map<String, Object> config = new HashMap<>();
-        config.put(MilvusSinkConfig.URL.key(), this.container.getEndpoint());
-        config.put(MilvusSinkConfig.TOKEN.key(), TOKEN);
+        config.put(MilvusSinkOptions.URL.key(), this.container.getEndpoint());
+        config.put(MilvusSinkOptions.TOKEN.key(), TOKEN);
         ReadonlyConfig readonlyConfig = ReadonlyConfig.fromMap(config);
         catalog = new MilvusCatalog(COLLECTION_NAME, readonlyConfig);
         catalog.open();

Original file line number	Diff line number	Diff line change
`@@ -27,7 +27,7 @@`
`27`	`27`	`import org.apache.seatunnel.api.table.catalog.CatalogTable;`
`28`	`28`	`import org.apache.seatunnel.api.table.catalog.TablePath;`
`29`	`29`	`import org.apache.seatunnel.api.table.type.SeaTunnelRow;`
`30`		`-import org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSourceConfig;`
	`30`	`+import org.apache.seatunnel.connectors.seatunnel.milvus.config.MilvusSourceOptions;`
`31`	`31`	`import org.apache.seatunnel.connectors.seatunnel.milvus.utils.MilvusConvertUtils;`
`32`	`32`
`33`	`33`	`import java.util.ArrayList;`
`@@ -79,6 +79,6 @@ public SourceSplitEnumerator<MilvusSourceSplit, MilvusSourceState> restoreEnumer`
`79`	`79`
`80`	`80`	`@Override`
`81`	`81`	`public String getPluginName() {`
`82`		`- return MilvusSourceConfig.CONNECTOR_IDENTITY;`
	`82`	`+ return MilvusSourceOptions.CONNECTOR_IDENTITY;`
`83`	`83`	`}`
`84`	`84`	`}`