[Bug] [dinky-common] Fix deserialization exceptions caused by incorre…

…ct get methods in enum fields. (#4082)
DataLinkDC · Dec 24, 2024 · 91af61a · 91af61a
1 parent 0f14777
commit 91af61a
Showing 1 changed file with 6 additions and 16 deletions.
diff --git a/dinky-common/src/main/java/org/dinky/data/enums/GatewayType.java b/dinky-common/src/main/java/org/dinky/data/enums/GatewayType.java
@@ -21,11 +21,14 @@
 
 import org.dinky.assertion.Asserts;
 
+import lombok.Getter;
+
 /**
  * SubmitType
  *
  * @since 2021/10/29
  */
+@Getter
 public enum GatewayType {
     LOCAL("l", "local"),
     STANDALONE("s", "standalone"),
@@ -44,30 +47,17 @@ public enum GatewayType {
         this.longValue = longValue;
     }
 
-    public String getValue() {
-        return value;
-    }
-
-    public String getLongValue() {
-        return longValue;
-    }
-
     public static GatewayType get(String value) {
         for (GatewayType type : GatewayType.values()) {
-            if (Asserts.isEquals(type.getValue(), value) || Asserts.isEquals(type.getLongValue(), value)) {
+            if (Asserts.isEquals(type.getValue(), value)
+                    || Asserts.isEquals(type.getLongValue(), value)
+                    || Asserts.isEquals(type.toString(), value)) {
                 return type;
             }
         }
         return GatewayType.LOCAL;
     }
 
-    public static GatewayType getSessionType(String value) {
-        if (value.contains("kubernetes")) {
-            return GatewayType.KUBERNETES_SESSION;
-        }
-        return GatewayType.YARN_SESSION;
-    }
-
     public GatewayType getSessionType() {
         if (longValue.contains("kubernetes")) {
             return GatewayType.KUBERNETES_SESSION;