Skip to content

Commit

Permalink
[Fix][Connector-V2] Remove Some Incorrect Comments and Properties in …
Browse files Browse the repository at this point in the history
…ElasticsearchCommitInfo
  • Loading branch information
xiaochen-zhou committed May 6, 2024
1 parent 9c36c45 commit 7202987
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 17 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -19,8 +19,4 @@

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 {}
Original file line number Diff line number Diff line change
Expand Up @@ -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 {}

0 comments on commit 7202987

Please sign in to comment.