This is an automated email from the ASF dual-hosted git repository.
jiafengzheng pushed a commit to branch branch-for-flink-before-1.13
in repository
https://gitbox.apache.org/repos/asf/incubator-doris-flink-connector.git
The following commit(s) were added to refs/heads/branch-for-flink-before-1.13
by this push:
new 52c431b add serialVersionUID (#22)
52c431b is described below
commit 52c431b16a52517de9fc7c4263718e9959e404d3
Author: wudi <[email protected]>
AuthorDate: Fri Mar 25 12:11:48 2022 +0800
add serialVersionUID (#22)
add serialVersionUID
---
.../main/java/org/apache/doris/flink/cfg/GenericDorisSinkFunction.java | 1 +
.../main/java/org/apache/doris/flink/datastream/DorisSourceFunction.java | 1 +
.../main/java/org/apache/doris/flink/table/DorisDynamicOutputFormat.java | 1 +
.../src/main/java/org/apache/doris/flink/table/DorisStreamLoad.java | 1 +
.../src/main/java/org/apache/doris/flink/table/DorisTableInputSplit.java | 1 +
5 files changed, 5 insertions(+)
diff --git
a/flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/GenericDorisSinkFunction.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/GenericDorisSinkFunction.java
index 6be6aa4..0ea11d0 100644
---
a/flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/GenericDorisSinkFunction.java
+++
b/flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/GenericDorisSinkFunction.java
@@ -31,6 +31,7 @@ import javax.annotation.Nonnull;
public class GenericDorisSinkFunction<T> extends RichSinkFunction<T>
implements CheckpointedFunction {
+ private static final long serialVersionUID = 1L;
private final DorisDynamicOutputFormat outputFormat;
public GenericDorisSinkFunction(@Nonnull DorisDynamicOutputFormat
outputFormat) {
diff --git
a/flink-doris-connector/src/main/java/org/apache/doris/flink/datastream/DorisSourceFunction.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/datastream/DorisSourceFunction.java
index edde953..df2a576 100644
---
a/flink-doris-connector/src/main/java/org/apache/doris/flink/datastream/DorisSourceFunction.java
+++
b/flink-doris-connector/src/main/java/org/apache/doris/flink/datastream/DorisSourceFunction.java
@@ -40,6 +40,7 @@ import java.util.List;
public class DorisSourceFunction extends RichParallelSourceFunction<List<?>>
implements ResultTypeQueryable<List<?>> {
+ private static final long serialVersionUID = 1L;
private static final Logger logger =
LoggerFactory.getLogger(DorisSourceFunction.class);
private final DorisDeserializationSchema<List<?>> deserializer;
diff --git
a/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicOutputFormat.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicOutputFormat.java
index cd8dee0..3f51df6 100644
---
a/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicOutputFormat.java
+++
b/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicOutputFormat.java
@@ -59,6 +59,7 @@ import static
org.apache.flink.table.data.RowData.createFieldGetter;
**/
public class DorisDynamicOutputFormat<T> extends RichOutputFormat<T> {
+ private static final long serialVersionUID = 1L;
private static final Logger LOG =
LoggerFactory.getLogger(DorisDynamicOutputFormat.class);
private static final ObjectMapper OBJECT_MAPPER = new ObjectMapper();
diff --git
a/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisStreamLoad.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisStreamLoad.java
index 9c05b83..0d5ba7f 100644
---
a/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisStreamLoad.java
+++
b/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisStreamLoad.java
@@ -51,6 +51,7 @@ import java.util.UUID;
**/
public class DorisStreamLoad implements Serializable {
+ private static final long serialVersionUID = 1L;
private static final Logger LOG =
LoggerFactory.getLogger(DorisStreamLoad.class);
private static final ObjectMapper OBJECT_MAPPER = new ObjectMapper();
diff --git
a/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisTableInputSplit.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisTableInputSplit.java
index 5e81cc1..c9db66e 100644
---
a/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisTableInputSplit.java
+++
b/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisTableInputSplit.java
@@ -24,6 +24,7 @@ import org.apache.flink.core.io.InputSplit;
**/
public class DorisTableInputSplit implements InputSplit, java.io.Serializable {
+ private static final long serialVersionUID = 1L;
/**
* The number of the split.
*/
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
