This is an automated email from the ASF dual-hosted git repository.
danny0405 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push:
new 659a6fd2e13 [HUDI-7387] Serializable Class need contains
serialVersionUID to keep compatibility in upgrade (#10633)
659a6fd2e13 is described below
commit 659a6fd2e13cd47e58f1246a7af5de57fdee960e
Author: xuzifu666 <[email protected]>
AuthorDate: Thu Feb 8 11:43:23 2024 +0800
[HUDI-7387] Serializable Class need contains serialVersionUID to keep
compatibility in upgrade (#10633)
---
.../src/main/java/org/apache/hudi/client/BaseHoodieClient.java | 1 +
.../src/main/java/org/apache/hudi/table/action/BaseActionExecutor.java | 1 +
.../java/org/apache/hudi/table/action/rollback/BaseRollbackHelper.java | 1 +
.../hudi-flink/src/main/java/org/apache/hudi/schema/SchemaProvider.java | 2 ++
.../main/java/org/apache/hudi/utilities/HoodieDataTableValidator.java | 1 +
.../main/java/org/apache/hudi/utilities/HoodieDropPartitionsTool.java | 1 +
.../java/org/apache/hudi/utilities/HoodieMetadataTableValidator.java | 1 +
.../src/main/java/org/apache/hudi/utilities/HoodieSnapshotCopier.java | 1 +
.../main/java/org/apache/hudi/utilities/HoodieWithTimelineServer.java | 1 +
.../src/main/java/org/apache/hudi/utilities/TableSizeStats.java | 1 +
10 files changed, 11 insertions(+)
diff --git
a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/BaseHoodieClient.java
b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/BaseHoodieClient.java
index 153ab7424be..a88030c9a2c 100644
---
a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/BaseHoodieClient.java
+++
b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/BaseHoodieClient.java
@@ -64,6 +64,7 @@ public abstract class BaseHoodieClient implements
Serializable, AutoCloseable {
private static final Logger LOG =
LoggerFactory.getLogger(BaseHoodieClient.class);
+ private static final long serialVersionUID = 1L;
protected final transient FileSystem fs;
protected final transient HoodieEngineContext context;
protected final transient Configuration hadoopConf;
diff --git
a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/BaseActionExecutor.java
b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/BaseActionExecutor.java
index 13d43040dd8..c0683946b9b 100644
---
a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/BaseActionExecutor.java
+++
b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/BaseActionExecutor.java
@@ -36,6 +36,7 @@ import org.apache.hudi.table.HoodieTable;
public abstract class BaseActionExecutor<T, I, K, O, R> implements
Serializable {
+ private static final long serialVersionUID = 1L;
protected final transient HoodieEngineContext context;
protected final transient Configuration hadoopConf;
diff --git
a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/BaseRollbackHelper.java
b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/BaseRollbackHelper.java
index b261030e8ab..2793b905e7c 100644
---
a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/BaseRollbackHelper.java
+++
b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/BaseRollbackHelper.java
@@ -56,6 +56,7 @@ import java.util.stream.Stream;
*/
public class BaseRollbackHelper implements Serializable {
+ private static final long serialVersionUID = 1L;
private static final Logger LOG =
LoggerFactory.getLogger(BaseRollbackHelper.class);
protected static final String EMPTY_STRING = "";
diff --git
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/schema/SchemaProvider.java
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/schema/SchemaProvider.java
index 5def413b502..eba4e51861d 100644
---
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/schema/SchemaProvider.java
+++
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/schema/SchemaProvider.java
@@ -27,6 +27,8 @@ import java.io.Serializable;
*/
public abstract class SchemaProvider implements Serializable {
+ private static final long serialVersionUID = 1L;
+
public abstract Schema getSourceSchema();
public Schema getTargetSchema() {
diff --git
a/hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieDataTableValidator.java
b/hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieDataTableValidator.java
index 523d119f309..e1a837d02ae 100644
---
a/hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieDataTableValidator.java
+++
b/hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieDataTableValidator.java
@@ -95,6 +95,7 @@ import java.util.stream.Stream;
*/
public class HoodieDataTableValidator implements Serializable {
+ private static final long serialVersionUID = 1L;
private static final Logger LOG =
LoggerFactory.getLogger(HoodieDataTableValidator.class);
// Spark context
diff --git
a/hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieDropPartitionsTool.java
b/hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieDropPartitionsTool.java
index 7b881a3579e..449e5e45640 100644
---
a/hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieDropPartitionsTool.java
+++
b/hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieDropPartitionsTool.java
@@ -106,6 +106,7 @@ import scala.Tuple2;
*/
public class HoodieDropPartitionsTool implements Serializable {
+ private static final long serialVersionUID = 1L;
private static final Logger LOG =
LoggerFactory.getLogger(HoodieDropPartitionsTool.class);
// Spark context
private final transient JavaSparkContext jsc;
diff --git
a/hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieMetadataTableValidator.java
b/hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieMetadataTableValidator.java
index b4c7137a19c..4cebbf0b3cc 100644
---
a/hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieMetadataTableValidator.java
+++
b/hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieMetadataTableValidator.java
@@ -164,6 +164,7 @@ import static
org.apache.hudi.metadata.HoodieTableMetadata.getMetadataTableBaseP
*/
public class HoodieMetadataTableValidator implements Serializable {
+ private static final long serialVersionUID = 1L;
private static final Logger LOG =
LoggerFactory.getLogger(HoodieMetadataTableValidator.class);
// Spark context
diff --git
a/hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieSnapshotCopier.java
b/hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieSnapshotCopier.java
index 999c7612291..5d7402e434e 100644
---
a/hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieSnapshotCopier.java
+++
b/hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieSnapshotCopier.java
@@ -63,6 +63,7 @@ import static
org.apache.hudi.utilities.UtilHelpers.buildSparkConf;
*/
public class HoodieSnapshotCopier implements Serializable {
+ private static final long serialVersionUID = 1L;
private static final Logger LOG =
LoggerFactory.getLogger(HoodieSnapshotCopier.class);
static class Config implements Serializable {
diff --git
a/hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieWithTimelineServer.java
b/hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieWithTimelineServer.java
index 326f56a628e..e2c23b15153 100644
---
a/hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieWithTimelineServer.java
+++
b/hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieWithTimelineServer.java
@@ -43,6 +43,7 @@ import java.util.stream.IntStream;
public class HoodieWithTimelineServer implements Serializable {
+ private static final long serialVersionUID = 1L;
private final Config cfg;
public HoodieWithTimelineServer(Config cfg) {
diff --git
a/hudi-utilities/src/main/java/org/apache/hudi/utilities/TableSizeStats.java
b/hudi-utilities/src/main/java/org/apache/hudi/utilities/TableSizeStats.java
index 4c37a5d3f9a..813a9fa7f04 100644
--- a/hudi-utilities/src/main/java/org/apache/hudi/utilities/TableSizeStats.java
+++ b/hudi-utilities/src/main/java/org/apache/hudi/utilities/TableSizeStats.java
@@ -95,6 +95,7 @@ import java.util.stream.Collectors;
*/
public class TableSizeStats implements Serializable {
+ private static final long serialVersionUID = 1L;
private static final Logger LOG =
LoggerFactory.getLogger(TableSizeStats.class);
// Date formatter for parsing partition dates (example: 2023/5/5/ or
2023-5-5).
