You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by ki...@apache.org on 2022/01/29 02:13:17 UTC
[incubator-seatunnel] branch dev updated: [SeaTunnel#1108] Add serialVersionUID for Serializable classes (#1109)
This is an automated email from the ASF dual-hosted git repository.
kirs 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 92fe127 [SeaTunnel#1108] Add serialVersionUID for Serializable classes (#1109)
92fe127 is described below
commit 92fe127447d3779d092f147c1c5eb158266b412f
Author: Benedict Jin <as...@apache.org>
AuthorDate: Sat Jan 29 10:13:12 2022 +0800
[SeaTunnel#1108] Add serialVersionUID for Serializable classes (#1109)
---
.../src/main/java/org/apache/seatunnel/flink/sink/ConsoleSink.java | 1 +
.../main/java/org/apache/seatunnel/flink/sink/DorisOutputFormat.java | 1 +
.../src/main/java/org/apache/seatunnel/flink/sink/DorisSink.java | 1 +
.../main/java/org/apache/seatunnel/flink/sink/DorisSinkFunction.java | 1 +
.../src/main/java/org/apache/seatunnel/flink/sink/DorisStreamLoad.java | 1 +
.../main/java/org/apache/seatunnel/flink/sink/DruidOutputFormat.java | 1 +
.../src/main/java/org/apache/seatunnel/flink/sink/DruidSink.java | 1 +
.../main/java/org/apache/seatunnel/flink/source/DruidInputFormat.java | 1 +
.../src/main/java/org/apache/seatunnel/flink/source/DruidSource.java | 1 +
.../src/main/java/org/apache/seatunnel/flink/sink/Elasticsearch.java | 1 +
.../java/org/apache/seatunnel/flink/sink/ElasticsearchOutputFormat.java | 1 +
.../main/java/org/apache/seatunnel/flink/source/FakeSourceStream.java | 1 +
.../main/java/org/apache/seatunnel/flink/sink/CsvRowOutputFormat.java | 1 +
.../src/main/java/org/apache/seatunnel/flink/sink/FileSink.java | 2 ++
.../src/main/java/org/apache/seatunnel/flink/source/FileSource.java | 1 +
.../main/java/org/apache/seatunnel/flink/source/JsonRowInputFormat.java | 1 +
.../main/java/org/apache/seatunnel/flink/source/TextRowInputFormat.java | 2 ++
.../main/java/org/apache/seatunnel/flink/sink/InfluxDbOutputFormat.java | 1 +
.../src/main/java/org/apache/seatunnel/flink/sink/InfluxDbSink.java | 1 +
.../src/main/java/org/apache/seatunnel/flink/sink/JdbcSink.java | 1 +
.../src/main/java/org/apache/seatunnel/flink/source/JdbcSource.java | 1 +
.../src/main/java/org/apache/seatunnel/flink/sink/KafkaTable.java | 1 +
.../main/java/org/apache/seatunnel/flink/source/KafkaTableStream.java | 1 +
.../src/main/java/org/apache/seatunnel/flink/source/SocketStream.java | 1 +
.../java/org/apache/seatunnel/flink/transform/DataStreamToTable.java | 1 +
.../java/org/apache/seatunnel/flink/transform/TableToDataStream.java | 1 +
26 files changed, 28 insertions(+)
diff --git a/seatunnel-connectors/seatunnel-connector-flink-console/src/main/java/org/apache/seatunnel/flink/sink/ConsoleSink.java b/seatunnel-connectors/seatunnel-connector-flink-console/src/main/java/org/apache/seatunnel/flink/sink/ConsoleSink.java
index 9768882..5d82e0d 100644
--- a/seatunnel-connectors/seatunnel-connector-flink-console/src/main/java/org/apache/seatunnel/flink/sink/ConsoleSink.java
+++ b/seatunnel-connectors/seatunnel-connector-flink-console/src/main/java/org/apache/seatunnel/flink/sink/ConsoleSink.java
@@ -36,6 +36,7 @@ import java.io.IOException;
public class ConsoleSink extends RichOutputFormat<Row> implements FlinkBatchSink<Row, Row>, FlinkStreamSink<Row, Row> {
+ private static final long serialVersionUID = 3482649370594181723L;
private Config config;
@Override
diff --git a/seatunnel-connectors/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisOutputFormat.java b/seatunnel-connectors/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisOutputFormat.java
index f1ef410..a69ce37 100644
--- a/seatunnel-connectors/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisOutputFormat.java
+++ b/seatunnel-connectors/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisOutputFormat.java
@@ -44,6 +44,7 @@ import java.util.regex.Pattern;
**/
public class DorisOutputFormat<T> extends RichOutputFormat<T> {
private static final Logger LOGGER = LoggerFactory.getLogger(DorisOutputFormat.class);
+ private static final long serialVersionUID = -4514164348993670086L;
private static final long DEFAULT_INTERVAL_MS = TimeUnit.SECONDS.toMillis(1);
private static final ObjectMapper OBJECT_MAPPER = new ObjectMapper();
private static final String FIELD_DELIMITER_KEY = "column_separator";
diff --git a/seatunnel-connectors/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisSink.java b/seatunnel-connectors/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisSink.java
index b5043a3..c92829b 100644
--- a/seatunnel-connectors/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisSink.java
+++ b/seatunnel-connectors/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisSink.java
@@ -41,6 +41,7 @@ import java.util.concurrent.TimeUnit;
public class DorisSink implements FlinkStreamSink<Row, Row>, FlinkBatchSink<Row, Row> {
+ private static final long serialVersionUID = 4747849769146047770L;
private static final int DEFAULT_BATCH_SIZE = 100;
private static final long DEFAULT_INTERVAL_MS = TimeUnit.SECONDS.toMillis(1);
diff --git a/seatunnel-connectors/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisSinkFunction.java b/seatunnel-connectors/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisSinkFunction.java
index 03c86f9..689f068 100644
--- a/seatunnel-connectors/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisSinkFunction.java
+++ b/seatunnel-connectors/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisSinkFunction.java
@@ -31,6 +31,7 @@ import javax.annotation.Nonnull;
public class DorisSinkFunction<T> extends RichSinkFunction<T>
implements CheckpointedFunction {
+ private static final long serialVersionUID = -2259171589402599426L;
private final DorisOutputFormat outputFormat;
public DorisSinkFunction(@Nonnull DorisOutputFormat outputFormat) {
diff --git a/seatunnel-connectors/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisStreamLoad.java b/seatunnel-connectors/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisStreamLoad.java
index e82f239..0cd10b3 100644
--- a/seatunnel-connectors/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisStreamLoad.java
+++ b/seatunnel-connectors/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisStreamLoad.java
@@ -46,6 +46,7 @@ import java.util.UUID;
public class DorisStreamLoad implements Serializable {
private static final Logger LOGGER = LoggerFactory.getLogger(DorisStreamLoad.class);
+ private static final long serialVersionUID = -595233501819950489L;
private static final List<String> DORIS_SUCCESS_STATUS = Arrays.asList("Success", "Publish Timeout");
private static final ObjectMapper OBJECT_MAPPER = new ObjectMapper();
private static final String LOAD_URL_PATTERN = "http://%s/api/%s/%s/_stream_load?";
diff --git a/seatunnel-connectors/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/sink/DruidOutputFormat.java b/seatunnel-connectors/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/sink/DruidOutputFormat.java
index 1a638b7..01d910e 100644
--- a/seatunnel-connectors/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/sink/DruidOutputFormat.java
+++ b/seatunnel-connectors/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/sink/DruidOutputFormat.java
@@ -57,6 +57,7 @@ import java.util.Collections;
public class DruidOutputFormat extends RichOutputFormat<Row> {
private static final Logger LOGGER = LoggerFactory.getLogger(DruidOutputFormat.class);
+ private static final long serialVersionUID = -7410857670269773005L;
private static final String DEFAULT_TIMESTAMP_COLUMN = "timestamp";
private static final String DEFAULT_TIMESTAMP_FORMAT = "auto";
diff --git a/seatunnel-connectors/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/sink/DruidSink.java b/seatunnel-connectors/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/sink/DruidSink.java
index 4c25b2c..83f6f87 100644
--- a/seatunnel-connectors/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/sink/DruidSink.java
+++ b/seatunnel-connectors/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/sink/DruidSink.java
@@ -30,6 +30,7 @@ import org.apache.flink.types.Row;
public class DruidSink implements FlinkBatchSink<Row, Row> {
+ private static final long serialVersionUID = -2967782261362988646L;
private static final String COORDINATOR_URL = "coordinator_url";
private static final String DATASOURCE = "datasource";
private static final String TIMESTAMP_COLUMN = "timestamp_column";
diff --git a/seatunnel-connectors/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/source/DruidInputFormat.java b/seatunnel-connectors/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/source/DruidInputFormat.java
index 4c99d65..4c236fa 100644
--- a/seatunnel-connectors/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/source/DruidInputFormat.java
+++ b/seatunnel-connectors/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/source/DruidInputFormat.java
@@ -47,6 +47,7 @@ import java.util.Arrays;
public class DruidInputFormat extends RichInputFormat<Row, InputSplit> implements ResultTypeQueryable<Row> {
private static final Logger LOG = LoggerFactory.getLogger(DruidInputFormat.class);
+ private static final long serialVersionUID = 6404870251026854042L;
private String jdbcURL;
private String query;
diff --git a/seatunnel-connectors/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/source/DruidSource.java b/seatunnel-connectors/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/source/DruidSource.java
index d15d412..1b57162 100644
--- a/seatunnel-connectors/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/source/DruidSource.java
+++ b/seatunnel-connectors/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/source/DruidSource.java
@@ -53,6 +53,7 @@ import java.util.List;
public class DruidSource implements FlinkBatchSource<Row> {
+ private static final long serialVersionUID = 8152628883440481281L;
private static final Logger LOGGER = LoggerFactory.getLogger(DruidSource.class);
private Config config;
diff --git a/seatunnel-connectors/seatunnel-connector-flink-elasticsearch/src/main/java/org/apache/seatunnel/flink/sink/Elasticsearch.java b/seatunnel-connectors/seatunnel-connector-flink-elasticsearch/src/main/java/org/apache/seatunnel/flink/sink/Elasticsearch.java
index da01624..ed9697e 100644
--- a/seatunnel-connectors/seatunnel-connector-flink-elasticsearch/src/main/java/org/apache/seatunnel/flink/sink/Elasticsearch.java
+++ b/seatunnel-connectors/seatunnel-connector-flink-elasticsearch/src/main/java/org/apache/seatunnel/flink/sink/Elasticsearch.java
@@ -48,6 +48,7 @@ import java.util.Map;
public class Elasticsearch implements FlinkStreamSink<Row, Row>, FlinkBatchSink<Row, Row> {
+ private static final long serialVersionUID = 8445868321245456793L;
private static final int DEFAULT_CONFIG_SIZE = 3;
private Config config;
diff --git a/seatunnel-connectors/seatunnel-connector-flink-elasticsearch/src/main/java/org/apache/seatunnel/flink/sink/ElasticsearchOutputFormat.java b/seatunnel-connectors/seatunnel-connector-flink-elasticsearch/src/main/java/org/apache/seatunnel/flink/sink/ElasticsearchOutputFormat.java
index d673ffc..4d5c415 100644
--- a/seatunnel-connectors/seatunnel-connector-flink-elasticsearch/src/main/java/org/apache/seatunnel/flink/sink/ElasticsearchOutputFormat.java
+++ b/seatunnel-connectors/seatunnel-connector-flink-elasticsearch/src/main/java/org/apache/seatunnel/flink/sink/ElasticsearchOutputFormat.java
@@ -41,6 +41,7 @@ import java.util.List;
public class ElasticsearchOutputFormat<T> extends RichOutputFormat<T> {
+ private static final long serialVersionUID = 2048590860723433896L;
private static final Logger LOGGER = LoggerFactory.getLogger(ElasticsearchOutputFormat.class);
private Config config;
diff --git a/seatunnel-connectors/seatunnel-connector-flink-fake/src/main/java/org/apache/seatunnel/flink/source/FakeSourceStream.java b/seatunnel-connectors/seatunnel-connector-flink-fake/src/main/java/org/apache/seatunnel/flink/source/FakeSourceStream.java
index eef8891..b79fde1 100644
--- a/seatunnel-connectors/seatunnel-connector-flink-fake/src/main/java/org/apache/seatunnel/flink/source/FakeSourceStream.java
+++ b/seatunnel-connectors/seatunnel-connector-flink-fake/src/main/java/org/apache/seatunnel/flink/source/FakeSourceStream.java
@@ -36,6 +36,7 @@ import java.util.concurrent.TimeUnit;
public class FakeSourceStream extends RichParallelSourceFunction<Row> implements FlinkStreamSource<Row> {
+ private static final long serialVersionUID = -3026082767246767679L;
private volatile boolean running = true;
private Config config;
diff --git a/seatunnel-connectors/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/sink/CsvRowOutputFormat.java b/seatunnel-connectors/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/sink/CsvRowOutputFormat.java
index 622f725..c37db15 100644
--- a/seatunnel-connectors/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/sink/CsvRowOutputFormat.java
+++ b/seatunnel-connectors/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/sink/CsvRowOutputFormat.java
@@ -30,6 +30,7 @@ import java.io.Writer;
public class CsvRowOutputFormat extends FileOutputFormat<Row> {
+ private static final long serialVersionUID = 8646976668519603413L;
private static final int STREAM_BUFFER_SIZE = 4096;
public static final String DEFAULT_LINE_DELIMITER = CsvInputFormat.DEFAULT_LINE_DELIMITER;
public static final String DEFAULT_FIELD_DELIMITER = CsvInputFormat.DEFAULT_FIELD_DELIMITER;
diff --git a/seatunnel-connectors/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/sink/FileSink.java b/seatunnel-connectors/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/sink/FileSink.java
index cf8dbca..bc02392 100644
--- a/seatunnel-connectors/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/sink/FileSink.java
+++ b/seatunnel-connectors/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/sink/FileSink.java
@@ -46,6 +46,8 @@ public class FileSink implements FlinkStreamSink<Row, Row>, FlinkBatchSink<Row,
private static final Logger LOGGER = LoggerFactory.getLogger(FileSink.class);
+ private static final long serialVersionUID = -1648045076508797396L;
+
private static final String PATH = "path";
private static final String FORMAT = "format";
private static final String WRITE_MODE = "write_mode";
diff --git a/seatunnel-connectors/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/source/FileSource.java b/seatunnel-connectors/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/source/FileSource.java
index e3093c1..f3439f7 100644
--- a/seatunnel-connectors/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/source/FileSource.java
+++ b/seatunnel-connectors/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/source/FileSource.java
@@ -44,6 +44,7 @@ import java.util.Map;
public class FileSource implements FlinkBatchSource<Row> {
+ private static final long serialVersionUID = -5206798549756998426L;
private static final int DEFAULT_BATCH_SIZE = 1000;
private Config config;
diff --git a/seatunnel-connectors/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/source/JsonRowInputFormat.java b/seatunnel-connectors/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/source/JsonRowInputFormat.java
index 4d55f16..5cdc23d 100644
--- a/seatunnel-connectors/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/source/JsonRowInputFormat.java
+++ b/seatunnel-connectors/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/source/JsonRowInputFormat.java
@@ -32,6 +32,7 @@ import java.io.IOException;
public class JsonRowInputFormat extends DelimitedInputFormat<Row> implements ResultTypeQueryable<Row> {
+ private static final long serialVersionUID = 3256896054712026638L;
private RowTypeInfo rowTypeInfo;
private static final byte CARRIAGE_RETURN = (byte) '\r';
diff --git a/seatunnel-connectors/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/source/TextRowInputFormat.java b/seatunnel-connectors/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/source/TextRowInputFormat.java
index a11c8ad..310fc45 100644
--- a/seatunnel-connectors/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/source/TextRowInputFormat.java
+++ b/seatunnel-connectors/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/source/TextRowInputFormat.java
@@ -32,6 +32,8 @@ import java.util.Arrays;
public class TextRowInputFormat extends DelimitedInputFormat<Row> implements ResultTypeQueryable<Row> {
+ private static final long serialVersionUID = -7881695870867510222L;
+
private static final byte CARRIAGE_RETURN = (byte) '\r';
private static final byte NEW_LINE = (byte) '\n';
diff --git a/seatunnel-connectors/seatunnel-connector-flink-influxdb/src/main/java/org/apache/seatunnel/flink/sink/InfluxDbOutputFormat.java b/seatunnel-connectors/seatunnel-connector-flink-influxdb/src/main/java/org/apache/seatunnel/flink/sink/InfluxDbOutputFormat.java
index dddffe9..9fc3759 100644
--- a/seatunnel-connectors/seatunnel-connector-flink-influxdb/src/main/java/org/apache/seatunnel/flink/sink/InfluxDbOutputFormat.java
+++ b/seatunnel-connectors/seatunnel-connector-flink-influxdb/src/main/java/org/apache/seatunnel/flink/sink/InfluxDbOutputFormat.java
@@ -31,6 +31,7 @@ import java.util.concurrent.TimeUnit;
public class InfluxDbOutputFormat extends RichOutputFormat<Row> {
+ private static final long serialVersionUID = 22664885413601039L;
private final InfluxDB influxDB;
private final String measurement;
private final List<String> tags;
diff --git a/seatunnel-connectors/seatunnel-connector-flink-influxdb/src/main/java/org/apache/seatunnel/flink/sink/InfluxDbSink.java b/seatunnel-connectors/seatunnel-connector-flink-influxdb/src/main/java/org/apache/seatunnel/flink/sink/InfluxDbSink.java
index 67a820f..72be132 100644
--- a/seatunnel-connectors/seatunnel-connector-flink-influxdb/src/main/java/org/apache/seatunnel/flink/sink/InfluxDbSink.java
+++ b/seatunnel-connectors/seatunnel-connector-flink-influxdb/src/main/java/org/apache/seatunnel/flink/sink/InfluxDbSink.java
@@ -32,6 +32,7 @@ import java.util.List;
public class InfluxDbSink implements FlinkBatchSink<Row, Row> {
+ private static final long serialVersionUID = 7358988750295693096L;
private static final String SERVER_URL = "server_url";
private static final String USER_NAME = "username";
private static final String PASSWORD = "password";
diff --git a/seatunnel-connectors/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/sink/JdbcSink.java b/seatunnel-connectors/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/sink/JdbcSink.java
index 5b4ab8a..24244da 100644
--- a/seatunnel-connectors/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/sink/JdbcSink.java
+++ b/seatunnel-connectors/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/sink/JdbcSink.java
@@ -39,6 +39,7 @@ import org.apache.flink.types.Row;
public class JdbcSink implements FlinkStreamSink<Row, Row>, FlinkBatchSink<Row, Row> {
+ private static final long serialVersionUID = 3677571223952518115L;
private static final int DEFAULT_BATCH_SIZE = 5000;
private Config config;
diff --git a/seatunnel-connectors/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/source/JdbcSource.java b/seatunnel-connectors/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/source/JdbcSource.java
index c7f5235..5abf144 100644
--- a/seatunnel-connectors/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/source/JdbcSource.java
+++ b/seatunnel-connectors/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/source/JdbcSource.java
@@ -57,6 +57,7 @@ import java.util.regex.Pattern;
public class JdbcSource implements FlinkBatchSource<Row> {
+ private static final long serialVersionUID = -3349505356339446415L;
private static final Logger LOGGER = LoggerFactory.getLogger(JdbcSource.class);
private Config config;
diff --git a/seatunnel-connectors/seatunnel-connector-flink-kafka/src/main/java/org/apache/seatunnel/flink/sink/KafkaTable.java b/seatunnel-connectors/seatunnel-connector-flink-kafka/src/main/java/org/apache/seatunnel/flink/sink/KafkaTable.java
index f750f7a..87563e6 100644
--- a/seatunnel-connectors/seatunnel-connector-flink-kafka/src/main/java/org/apache/seatunnel/flink/sink/KafkaTable.java
+++ b/seatunnel-connectors/seatunnel-connector-flink-kafka/src/main/java/org/apache/seatunnel/flink/sink/KafkaTable.java
@@ -42,6 +42,7 @@ import java.util.Properties;
public class KafkaTable implements FlinkStreamSink<Row, Row> {
+ private static final long serialVersionUID = 3980751499724935230L;
private Config config;
private Properties kafkaParams = new Properties();
private String topic;
diff --git a/seatunnel-connectors/seatunnel-connector-flink-kafka/src/main/java/org/apache/seatunnel/flink/source/KafkaTableStream.java b/seatunnel-connectors/seatunnel-connector-flink-kafka/src/main/java/org/apache/seatunnel/flink/source/KafkaTableStream.java
index 7a7a503..832a8f0 100644
--- a/seatunnel-connectors/seatunnel-connector-flink-kafka/src/main/java/org/apache/seatunnel/flink/source/KafkaTableStream.java
+++ b/seatunnel-connectors/seatunnel-connector-flink-kafka/src/main/java/org/apache/seatunnel/flink/source/KafkaTableStream.java
@@ -47,6 +47,7 @@ import java.util.Properties;
public class KafkaTableStream implements FlinkStreamSource<Row> {
+ private static final long serialVersionUID = 5287018194573371428L;
private static final Logger LOGGER = LoggerFactory.getLogger(KafkaTableStream.class);
private Config config;
diff --git a/seatunnel-connectors/seatunnel-connector-flink-socket/src/main/java/org/apache/seatunnel/flink/source/SocketStream.java b/seatunnel-connectors/seatunnel-connector-flink-socket/src/main/java/org/apache/seatunnel/flink/source/SocketStream.java
index dd7a299..7c05932 100644
--- a/seatunnel-connectors/seatunnel-connector-flink-socket/src/main/java/org/apache/seatunnel/flink/source/SocketStream.java
+++ b/seatunnel-connectors/seatunnel-connector-flink-socket/src/main/java/org/apache/seatunnel/flink/source/SocketStream.java
@@ -33,6 +33,7 @@ import org.apache.flink.types.Row;
public class SocketStream implements FlinkStreamSource<Row> {
+ private static final long serialVersionUID = 986629276153771291L;
private Config config;
private static final String HOST = "host";
diff --git a/seatunnel-transforms/seatunnel-transform-flink-datastream2table/src/main/java/org/apache/seatunnel/flink/transform/DataStreamToTable.java b/seatunnel-transforms/seatunnel-transform-flink-datastream2table/src/main/java/org/apache/seatunnel/flink/transform/DataStreamToTable.java
index 5249154..fffcfbd 100644
--- a/seatunnel-transforms/seatunnel-transform-flink-datastream2table/src/main/java/org/apache/seatunnel/flink/transform/DataStreamToTable.java
+++ b/seatunnel-transforms/seatunnel-transform-flink-datastream2table/src/main/java/org/apache/seatunnel/flink/transform/DataStreamToTable.java
@@ -33,6 +33,7 @@ import org.apache.flink.types.Row;
public class DataStreamToTable implements FlinkStreamTransform<Row, Row>, FlinkBatchTransform<Row, Row> {
+ private static final long serialVersionUID = -7861928245025199286L;
private Config config;
@Override
diff --git a/seatunnel-transforms/seatunnel-transform-flink-table2datastream/src/main/java/org/apache/seatunnel/flink/transform/TableToDataStream.java b/seatunnel-transforms/seatunnel-transform-flink-table2datastream/src/main/java/org/apache/seatunnel/flink/transform/TableToDataStream.java
index ee8ff48..0b3d04d 100644
--- a/seatunnel-transforms/seatunnel-transform-flink-table2datastream/src/main/java/org/apache/seatunnel/flink/transform/TableToDataStream.java
+++ b/seatunnel-transforms/seatunnel-transform-flink-table2datastream/src/main/java/org/apache/seatunnel/flink/transform/TableToDataStream.java
@@ -36,6 +36,7 @@ import org.apache.flink.types.Row;
public class TableToDataStream implements FlinkStreamTransform<Row, Row>, FlinkBatchTransform<Row, Row> {
+ private static final long serialVersionUID = 4556842426965038124L;
private Config config;
private boolean isAppend;