[incubator-seatunnel] branch dev updated: [hotfix][connector-v2][elasticsearch] Fix bulk refresh operation not locked (#3738)

[wanghailin]

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

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


The following commit(s) were added to refs/heads/dev by this push:
     new b6cab90d2 [hotfix][connector-v2][elasticsearch] Fix bulk refresh 
operation not locked (#3738)
b6cab90d2 is described below

commit b6cab90d2fdf78ef9d129eb5345f8cf27628bd05
Author: hailin0 <wanghai...@apache.org>
AuthorDate: Sat Dec 17 13:51:52 2022 +0800

    [hotfix][connector-v2][elasticsearch] Fix bulk refresh operation not locked 
(#3738)
---
 .../seatunnel/elasticsearch/sink/ElasticsearchSinkWriter.java           | 2 +-
 seatunnel-dist/src/main/assembly/assembly-bin-ci.xml                    | 1 +
 2 files changed, 2 insertions(+), 1 deletion(-)

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 13b46e67e..a088a9481 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
@@ -103,7 +103,7 @@ public class ElasticsearchSinkWriter implements 
SinkWriter<SeaTunnelRow, Elastic
     public void abortPrepare() {
     }
 
-    public void bulkEsWithRetry(EsRestClient esRestClient, List<String> 
requestEsList) {
+    public synchronized void bulkEsWithRetry(EsRestClient esRestClient, 
List<String> requestEsList) {
         try {
             RetryUtils.retryWithException(() -> {
                 if (requestEsList.size() > 0) {
diff --git a/seatunnel-dist/src/main/assembly/assembly-bin-ci.xml 
b/seatunnel-dist/src/main/assembly/assembly-bin-ci.xml
index 5fee9ae48..ecda3f384 100644
--- a/seatunnel-dist/src/main/assembly/assembly-bin-ci.xml
+++ b/seatunnel-dist/src/main/assembly/assembly-bin-ci.xml
@@ -147,6 +147,7 @@
                 <!-- Don't exclude connector-http-base, because it contains 
SPI files -->
                 <exclude>org.apache.seatunnel:connector-file-base</exclude>
                 
<exclude>org.apache.seatunnel:connector-file-base-hadoop</exclude>
+                <exclude>org.apache.seatunnel:connector-cdc-base</exclude>
             </excludes>
             <outputDirectory>/connectors/seatunnel</outputDirectory>
             <scope>provided</scope>