(seatunnel) branch dev updated: [Improve][connector-elasticsearch] Optimize Elasticsearch Sink vector parameters and documents (#10260)

[shenghang]

This is an automated email from the ASF dual-hosted git repository.

shenghang pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 0f6a3c5cd3 [Improve][connector-elasticsearch] Optimize Elasticsearch 
Sink vector parameters and documents (#10260)
0f6a3c5cd3 is described below

commit 0f6a3c5cd3cfdfe8e072bde2d6f5f93252d9741e
Author: 老王 <58297137+chl-...@users.noreply.github.com>
AuthorDate: Sat Jan 3 20:00:55 2026 +0800

    [Improve][connector-elasticsearch] Optimize Elasticsearch Sink vector 
parameters and documents (#10260)
---
 docs/en/connector-v2/sink/Elasticsearch.md                         | 7 ++++++-
 docs/zh/connector-v2/sink/Elasticsearch.md                         | 4 ++--
 .../seatunnel/elasticsearch/sink/ElasticsearchSinkFactory.java     | 6 +++++-
 3 files changed, 13 insertions(+), 4 deletions(-)

diff --git a/docs/en/connector-v2/sink/Elasticsearch.md 
b/docs/en/connector-v2/sink/Elasticsearch.md
index f466cddeff..17826fbe67 100644
--- a/docs/en/connector-v2/sink/Elasticsearch.md
+++ b/docs/en/connector-v2/sink/Elasticsearch.md
@@ -36,7 +36,6 @@ Engine Supported
 | auth.api_key_id         | string  | no       | -                            |
 | auth.api_key            | string  | no       | -                            |
 | auth.api_key_encoded    | string  | no       | -                            |
-
 | max_retry_count         | int     | no       | 3                            |
 | max_batch_size          | int     | no       | 10                           |
 | tls_verify_certificate  | boolean | no       | true                         |
@@ -94,6 +93,12 @@ Username for basic authentication (x-pack username).
 
 Password for basic authentication (x-pack password).
 
+### vectorization_fields [array]
+Field names that require vector conversion, supported by Elasticsearch 7.3 and 
later versions
+
+### vector_dimensions [int]
+Vector dimension, supported by Elasticsearch 7.3 and later versions
+
 **Example:**
 ```hocon
 sink {
diff --git a/docs/zh/connector-v2/sink/Elasticsearch.md 
b/docs/zh/connector-v2/sink/Elasticsearch.md
index 925562e959..57a216ec1e 100644
--- a/docs/zh/connector-v2/sink/Elasticsearch.md
+++ b/docs/zh/connector-v2/sink/Elasticsearch.md
@@ -77,10 +77,10 @@ x-pack 密码
 批次批量请求最大尝试大小
 
 ### vectorization_fields [array]
-需要向量转换的字段名
+需要向量转换的字段名，Elasticsearch 7.3及以后的版本支持
 
 ### vector_dimensions [int]
-向量维度
+向量维度，Elasticsearch 7.3及以后的版本支持
 
 ### max_batch_size [int]
 
diff --git 
a/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/sink/ElasticsearchSinkFactory.java
 
b/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/sink/ElasticsearchSinkFactory.java
index 8480ca9fb4..31b1438eec 100644
--- 
a/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/sink/ElasticsearchSinkFactory.java
+++ 
b/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/sink/ElasticsearchSinkFactory.java
@@ -50,6 +50,8 @@ import static 
org.apache.seatunnel.connectors.seatunnel.elasticsearch.config.Ela
 import static 
org.apache.seatunnel.connectors.seatunnel.elasticsearch.config.ElasticsearchSinkOptions.MAX_BATCH_SIZE;
 import static 
org.apache.seatunnel.connectors.seatunnel.elasticsearch.config.ElasticsearchSinkOptions.MAX_RETRY_COUNT;
 import static 
org.apache.seatunnel.connectors.seatunnel.elasticsearch.config.ElasticsearchSinkOptions.PRIMARY_KEYS;
+import static 
org.apache.seatunnel.connectors.seatunnel.elasticsearch.config.ElasticsearchSinkOptions.VECTORIZATION_FIELDS;
+import static 
org.apache.seatunnel.connectors.seatunnel.elasticsearch.config.ElasticsearchSinkOptions.VECTOR_DIMENSIONS;
 
 @AutoService(Factory.class)
 public class ElasticsearchSinkFactory implements TableSinkFactory {
@@ -80,7 +82,9 @@ public class ElasticsearchSinkFactory implements 
TableSinkFactory {
                         TLS_KEY_STORE_PASSWORD,
                         TLS_TRUST_STORE_PATH,
                         TLS_TRUST_STORE_PASSWORD,
-                        SinkConnectorCommonOptions.MULTI_TABLE_SINK_REPLICA)
+                        SinkConnectorCommonOptions.MULTI_TABLE_SINK_REPLICA,
+                        VECTORIZATION_FIELDS,
+                        VECTOR_DIMENSIONS)
                 .optional(AUTH_TYPE)
                 .conditional(AUTH_TYPE, AuthTypeEnum.API_KEY, API_KEY_ID, 
API_KEY)
                 .conditional(AUTH_TYPE, AuthTypeEnum.API_KEY_ENCODED, 
API_KEY_ENCODED)