This is an automated email from the ASF dual-hosted git repository.
benjobs pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
The following commit(s) were added to refs/heads/dev by this push:
new 367c6af33 [Cleanup] Remove the redundant Serializable implementation
for all Enums of the project. (#3131) (#3137)
367c6af33 is described below
commit 367c6af33a82f0b7c33f1c1ffa24d0499aa1400d
Author: ligen <[email protected]>
AuthorDate: Mon Sep 18 18:22:51 2023 +0800
[Cleanup] Remove the redundant Serializable implementation for all Enums of
the project. (#3131) (#3137)
Co-authored-by: ligen60 <[email protected]>
---
.../main/java/org/apache/streampark/common/enums/ApplicationType.java | 4 +---
.../main/java/org/apache/streampark/common/enums/ClusterState.java | 4 +---
.../main/java/org/apache/streampark/common/enums/DevelopmentMode.java | 4 +---
.../main/java/org/apache/streampark/common/enums/ExecutionMode.java | 3 +--
.../org/apache/streampark/common/enums/FlinkK8sRestExposedType.java | 4 +---
.../apache/streampark/common/enums/FlinkSqlValidationFailedType.java | 4 +---
.../main/java/org/apache/streampark/common/enums/ResolveOrder.java | 4 +---
.../src/main/java/org/apache/streampark/common/enums/RestoreMode.java | 3 +--
.../src/main/java/org/apache/streampark/common/enums/Semantic.java | 4 +---
.../src/main/java/org/apache/streampark/common/enums/StorageType.java | 4 +---
10 files changed, 10 insertions(+), 28 deletions(-)
diff --git
a/streampark-common/src/main/java/org/apache/streampark/common/enums/ApplicationType.java
b/streampark-common/src/main/java/org/apache/streampark/common/enums/ApplicationType.java
index 07683f56d..ed87b8a10 100644
---
a/streampark-common/src/main/java/org/apache/streampark/common/enums/ApplicationType.java
+++
b/streampark-common/src/main/java/org/apache/streampark/common/enums/ApplicationType.java
@@ -17,9 +17,7 @@
package org.apache.streampark.common.enums;
-import java.io.Serializable;
-
-public enum ApplicationType implements Serializable {
+public enum ApplicationType {
/** StreamPark Flink */
STREAMPARK_FLINK(1, "StreamPark Flink"),
/** Apache Flink */
diff --git
a/streampark-common/src/main/java/org/apache/streampark/common/enums/ClusterState.java
b/streampark-common/src/main/java/org/apache/streampark/common/enums/ClusterState.java
index beebd7b3f..284b60a36 100644
---
a/streampark-common/src/main/java/org/apache/streampark/common/enums/ClusterState.java
+++
b/streampark-common/src/main/java/org/apache/streampark/common/enums/ClusterState.java
@@ -17,10 +17,8 @@
package org.apache.streampark.common.enums;
-import java.io.Serializable;
-
/** @since 1.2.3 */
-public enum ClusterState implements Serializable {
+public enum ClusterState {
/** The cluster was just created but not started */
CREATED(0),
/** cluster started */
diff --git
a/streampark-common/src/main/java/org/apache/streampark/common/enums/DevelopmentMode.java
b/streampark-common/src/main/java/org/apache/streampark/common/enums/DevelopmentMode.java
index 6fdef4ce5..7bf3109ee 100644
---
a/streampark-common/src/main/java/org/apache/streampark/common/enums/DevelopmentMode.java
+++
b/streampark-common/src/main/java/org/apache/streampark/common/enums/DevelopmentMode.java
@@ -17,9 +17,7 @@
package org.apache.streampark.common.enums;
-import java.io.Serializable;
-
-public enum DevelopmentMode implements Serializable {
+public enum DevelopmentMode {
/** custom code */
CUSTOM_CODE("Custom Code", 1),
diff --git
a/streampark-common/src/main/java/org/apache/streampark/common/enums/ExecutionMode.java
b/streampark-common/src/main/java/org/apache/streampark/common/enums/ExecutionMode.java
index 8a347dea8..9ce12ea28 100644
---
a/streampark-common/src/main/java/org/apache/streampark/common/enums/ExecutionMode.java
+++
b/streampark-common/src/main/java/org/apache/streampark/common/enums/ExecutionMode.java
@@ -19,10 +19,9 @@ package org.apache.streampark.common.enums;
import com.google.common.collect.Lists;
-import java.io.Serializable;
import java.util.List;
-public enum ExecutionMode implements Serializable {
+public enum ExecutionMode {
/** Local mode */
LOCAL(0, "local"),
diff --git
a/streampark-common/src/main/java/org/apache/streampark/common/enums/FlinkK8sRestExposedType.java
b/streampark-common/src/main/java/org/apache/streampark/common/enums/FlinkK8sRestExposedType.java
index 29426e768..79f6e4196 100644
---
a/streampark-common/src/main/java/org/apache/streampark/common/enums/FlinkK8sRestExposedType.java
+++
b/streampark-common/src/main/java/org/apache/streampark/common/enums/FlinkK8sRestExposedType.java
@@ -17,10 +17,8 @@
package org.apache.streampark.common.enums;
-import java.io.Serializable;
-
/** kubernetes.rest-service.exposed.type */
-public enum FlinkK8sRestExposedType implements Serializable {
+public enum FlinkK8sRestExposedType {
/** LoadBalancer */
LOAD_BALANCER("LoadBalancer", 0),
diff --git
a/streampark-common/src/main/java/org/apache/streampark/common/enums/FlinkSqlValidationFailedType.java
b/streampark-common/src/main/java/org/apache/streampark/common/enums/FlinkSqlValidationFailedType.java
index cca8b6584..856c39bf9 100644
---
a/streampark-common/src/main/java/org/apache/streampark/common/enums/FlinkSqlValidationFailedType.java
+++
b/streampark-common/src/main/java/org/apache/streampark/common/enums/FlinkSqlValidationFailedType.java
@@ -17,9 +17,7 @@
package org.apache.streampark.common.enums;
-import java.io.Serializable;
-
-public enum FlinkSqlValidationFailedType implements Serializable {
+public enum FlinkSqlValidationFailedType {
/** Basic test failed (such as null, etc.) */
VERIFY_FAILED(1),
/** syntax error */
diff --git
a/streampark-common/src/main/java/org/apache/streampark/common/enums/ResolveOrder.java
b/streampark-common/src/main/java/org/apache/streampark/common/enums/ResolveOrder.java
index 06b85c88a..8a2b207e1 100644
---
a/streampark-common/src/main/java/org/apache/streampark/common/enums/ResolveOrder.java
+++
b/streampark-common/src/main/java/org/apache/streampark/common/enums/ResolveOrder.java
@@ -17,10 +17,8 @@
package org.apache.streampark.common.enums;
-import java.io.Serializable;
-
/** classloader.resolve-order */
-public enum ResolveOrder implements Serializable {
+public enum ResolveOrder {
/** parent-first */
PARENT_FIRST("parent-first", 0),
/** child-first */
diff --git
a/streampark-common/src/main/java/org/apache/streampark/common/enums/RestoreMode.java
b/streampark-common/src/main/java/org/apache/streampark/common/enums/RestoreMode.java
index 14e8e52c1..131507798 100644
---
a/streampark-common/src/main/java/org/apache/streampark/common/enums/RestoreMode.java
+++
b/streampark-common/src/main/java/org/apache/streampark/common/enums/RestoreMode.java
@@ -17,10 +17,9 @@
package org.apache.streampark.common.enums;
-import java.io.Serializable;
import java.util.Arrays;
-public enum RestoreMode implements Serializable {
+public enum RestoreMode {
NO_CLAIM(1),
CLAIM(2),
LEGACY(3);
diff --git
a/streampark-common/src/main/java/org/apache/streampark/common/enums/Semantic.java
b/streampark-common/src/main/java/org/apache/streampark/common/enums/Semantic.java
index e2a98650f..65dc3c5ea 100644
---
a/streampark-common/src/main/java/org/apache/streampark/common/enums/Semantic.java
+++
b/streampark-common/src/main/java/org/apache/streampark/common/enums/Semantic.java
@@ -17,9 +17,7 @@
package org.apache.streampark.common.enums;
-import java.io.Serializable;
-
-public enum Semantic implements Serializable {
+public enum Semantic {
/** */
EXACTLY_ONCE,
diff --git
a/streampark-common/src/main/java/org/apache/streampark/common/enums/StorageType.java
b/streampark-common/src/main/java/org/apache/streampark/common/enums/StorageType.java
index 61033e9e8..6890d669f 100644
---
a/streampark-common/src/main/java/org/apache/streampark/common/enums/StorageType.java
+++
b/streampark-common/src/main/java/org/apache/streampark/common/enums/StorageType.java
@@ -19,9 +19,7 @@ package org.apache.streampark.common.enums;
import org.apache.commons.lang3.StringUtils;
-import java.io.Serializable;
-
-public enum StorageType implements Serializable {
+public enum StorageType {
/** hdfs */
HDFS("hdfs"),
