Skip to content

Commit bf80160

Browse files
authored
[Bugfix][seatunnel-connectors-v2][connector-elasticsearch] ElasticsearchSink encounters a writing error and the task does not exit (#10038)
1 parent 5681fe3 commit bf80160

1 file changed

Lines changed: 6 additions & 3 deletions

File tree

  • seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/sink

seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/sink/ElasticsearchSinkWriter.java

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -208,8 +208,11 @@ public synchronized void bulkEsWithRetry(
208208
}
209209

210210
@Override
211-
public void close() throws IOException {
212-
bulkEsWithRetry(this.esRestClient, this.requestEsList);
213-
esRestClient.close();
211+
public void close() {
212+
try {
213+
bulkEsWithRetry(this.esRestClient, this.requestEsList);
214+
} finally {
215+
esRestClient.close();
216+
}
214217
}
215218
}

0 commit comments

Comments
 (0)