(seatunnel) branch dev updated: [Fix][Connector-V2] Remove Some Incorrect Comments and Properties in ElasticsearchCommitInfo

[fanjia]

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

fanjia 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 720298775a [Fix][Connector-V2] Remove Some Incorrect Comments and 
Properties in ElasticsearchCommitInfo
720298775a is described below

commit 720298775a659a382ac42d15878f1592c33ede5e
Author: xiaochen <598457...@qq.com>
AuthorDate: Mon May 6 21:28:54 2024 +0800

    [Fix][Connector-V2] Remove Some Incorrect Comments and Properties in 
ElasticsearchCommitInfo
---
 .../state/ElasticsearchAggregatedCommitInfo.java           |  4 ----
 .../elasticsearch/state/ElasticsearchCommitInfo.java       | 14 +-------------
 2 files changed, 1 insertion(+), 17 deletions(-)

diff --git 
a/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/state/ElasticsearchAggregatedCommitInfo.java
 
b/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/state/ElasticsearchAggregatedCommitInfo.java
index 9a569fe073..f5875a9728 100644
--- 
a/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/state/ElasticsearchAggregatedCommitInfo.java
+++ 
b/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/state/ElasticsearchAggregatedCommitInfo.java
@@ -19,8 +19,4 @@ package 
org.apache.seatunnel.connectors.seatunnel.elasticsearch.state;
 
 import java.io.Serializable;
 
-/**
- * Right now, we don't need aggregated commit in kafka. Todo: we need to add a 
default
- * implementation of this state.
- */
 public class ElasticsearchAggregatedCommitInfo implements Serializable {}
diff --git 
a/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/state/ElasticsearchCommitInfo.java
 
b/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/state/ElasticsearchCommitInfo.java
index 7b9174c360..68cb9b2a3e 100644
--- 
a/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/state/ElasticsearchCommitInfo.java
+++ 
b/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/state/ElasticsearchCommitInfo.java
@@ -17,18 +17,6 @@
 
 package org.apache.seatunnel.connectors.seatunnel.elasticsearch.state;
 
-import lombok.AllArgsConstructor;
-import lombok.Data;
-
 import java.io.Serializable;
-import java.util.Properties;
-
-@Data
-@AllArgsConstructor
-public class ElasticsearchCommitInfo implements Serializable {
 
-    private final String transactionId;
-    private final Properties kafkaProperties;
-    private final long producerId;
-    private final short epoch;
-}
+public class ElasticsearchCommitInfo implements Serializable {}