[incubator-seatunnel] branch dev updated: [Improve][ElasticsearchSink]remove useless code. (#4500)

[liugddx]

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

liugddx 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 ef44c0d44 [Improve][ElasticsearchSink]remove useless code. (#4500)
ef44c0d44 is described below

commit ef44c0d44a0667023e1a06652f422bd211b35a79
Author: lightzhao <40714172+lightz...@users.noreply.github.com>
AuthorDate: Mon Apr 17 21:18:46 2023 +0800

    [Improve][ElasticsearchSink]remove useless code. (#4500)
    
    Co-authored-by: lightzhao <zhaolianyong...@gmail.com>
---
 .../seatunnel/elasticsearch/sink/ElasticsearchSink.java          | 9 +--------
 .../seatunnel/elasticsearch/sink/ElasticsearchSinkWriter.java    | 3 +--
 2 files changed, 2 insertions(+), 10 deletions(-)

diff --git 
a/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/sink/ElasticsearchSink.java
 
b/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/sink/ElasticsearchSink.java
index f21d67a72..4ef7a26eb 100644
--- 
a/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/sink/ElasticsearchSink.java
+++ 
b/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/sink/ElasticsearchSink.java
@@ -31,8 +31,6 @@ import 
org.apache.seatunnel.connectors.seatunnel.elasticsearch.state.Elasticsear
 
 import com.google.auto.service.AutoService;
 
-import java.util.Collections;
-
 import static 
org.apache.seatunnel.connectors.seatunnel.elasticsearch.config.SinkConfig.MAX_BATCH_SIZE;
 import static 
org.apache.seatunnel.connectors.seatunnel.elasticsearch.config.SinkConfig.MAX_RETRY_COUNT;
 
@@ -81,11 +79,6 @@ public class ElasticsearchSink
     public SinkWriter<SeaTunnelRow, ElasticsearchCommitInfo, 
ElasticsearchSinkState> createWriter(
             SinkWriter.Context context) {
         return new ElasticsearchSinkWriter(
-                context,
-                seaTunnelRowType,
-                pluginConfig,
-                maxBatchSize,
-                maxRetryCount,
-                Collections.emptyList());
+                context, seaTunnelRowType, pluginConfig, maxBatchSize, 
maxRetryCount);
     }
 }
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 34d752c87..6e30397a4 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
@@ -65,8 +65,7 @@ public class ElasticsearchSinkWriter
             SeaTunnelRowType seaTunnelRowType,
             Config pluginConfig,
             int maxBatchSize,
-            int maxRetryCount,
-            List<ElasticsearchSinkState> elasticsearchStates) {
+            int maxRetryCount) {
         this.context = context;
         this.maxBatchSize = maxBatchSize;