(seatunnel) branch dev updated: [Bugfix][seatunnel-connectors-v2][connector-elasticsearch] ElasticsearchSink encounters a writing error and the task does not exit (#10038)

[lidongdai]

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

lidongdai 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 bf801605ea [Bugfix][seatunnel-connectors-v2][connector-elasticsearch] 
ElasticsearchSink encounters a writing error and the task does not exit (#10038)
bf801605ea is described below

commit bf801605eac69883fb45d42ba19c0e6012e90620
Author: 老王 <58297137+chl-...@users.noreply.github.com>
AuthorDate: Thu Nov 6 22:42:08 2025 +0800

    [Bugfix][seatunnel-connectors-v2][connector-elasticsearch] 
ElasticsearchSink encounters a writing error and the task does not exit (#10038)
---
 .../seatunnel/elasticsearch/sink/ElasticsearchSinkWriter.java    | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git 
a/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/sink/ElasticsearchSinkWriter.java
 
b/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/sink/ElasticsearchSinkWriter.java
index 3b897de6ea..a8a159cae1 100644
--- 
a/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/sink/ElasticsearchSinkWriter.java
+++ 
b/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/sink/ElasticsearchSinkWriter.java
@@ -208,8 +208,11 @@ public class ElasticsearchSinkWriter
     }
 
     @Override
-    public void close() throws IOException {
-        bulkEsWithRetry(this.esRestClient, this.requestEsList);
-        esRestClient.close();
+    public void close() {
+        try {
+            bulkEsWithRetry(this.esRestClient, this.requestEsList);
+        } finally {
+            esRestClient.close();
+        }
     }
 }