Skip to content

Commit b6cab90

Browse files
authored
[hotfix][connector-v2][elasticsearch] Fix bulk refresh operation not locked (#3738)
1 parent 8ef080f commit b6cab90

2 files changed

Lines changed: 2 additions & 1 deletion

File tree

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -103,7 +103,7 @@ public Optional<ElasticsearchCommitInfo> prepareCommit() {
103103
public void abortPrepare() {
104104
}
105105

106-
public void bulkEsWithRetry(EsRestClient esRestClient, List<String> requestEsList) {
106+
public synchronized void bulkEsWithRetry(EsRestClient esRestClient, List<String> requestEsList) {
107107
try {
108108
RetryUtils.retryWithException(() -> {
109109
if (requestEsList.size() > 0) {

seatunnel-dist/src/main/assembly/assembly-bin-ci.xml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -147,6 +147,7 @@
147147
<!-- Don't exclude connector-http-base, because it contains SPI files -->
148148
<exclude>org.apache.seatunnel:connector-file-base</exclude>
149149
<exclude>org.apache.seatunnel:connector-file-base-hadoop</exclude>
150+
<exclude>org.apache.seatunnel:connector-cdc-base</exclude>
150151
</excludes>
151152
<outputDirectory>/connectors/seatunnel</outputDirectory>
152153
<scope>provided</scope>

0 commit comments

Comments
 (0)