You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampark.apache.org by be...@apache.org on 2024/02/04 05:37:36 UTC
(incubator-streampark) branch dev-2.1.3 updated: [Improve] lombok improvement (#3533)
This is an automated email from the ASF dual-hosted git repository.
benjobs pushed a commit to branch dev-2.1.3
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
The following commit(s) were added to refs/heads/dev-2.1.3 by this push:
new 25313d402 [Improve] lombok improvement (#3533)
25313d402 is described below
commit 25313d4020cfe9096f3890cccd551a87a299c3c3
Author: benjobs <be...@apache.org>
AuthorDate: Sun Feb 4 13:37:31 2024 +0800
[Improve] lombok improvement (#3533)
Co-authored-by: benjobs <be...@gmail.com>
---
.../console/base/domain/RestRequest.java | 6 ++++--
.../console/base/domain/router/RouterMeta.java | 6 ++++--
.../console/base/domain/router/RouterTree.java | 6 ++++--
.../console/base/domain/router/VueRouter.java | 6 ++++--
.../console/base/properties/ShiroProperties.java | 6 ++++--
.../console/core/bean/AlertConfigWithParams.java | 6 ++++--
.../console/core/bean/AlertDingTalkParams.java | 6 ++++--
.../console/core/bean/AlertEmailParams.java | 6 ++++--
.../console/core/bean/AlertHttpCallbackParams.java | 6 ++++--
.../console/core/bean/AlertLarkParams.java | 6 ++++--
.../console/core/bean/AlertLarkRobotResponse.java | 6 ++++--
.../console/core/bean/AlertTemplate.java | 6 ++++--
.../console/core/bean/AlertWeComParams.java | 6 ++++--
.../core/bean/AppBuildDockerResolvedDetail.java | 18 ++++++++++++------
.../streampark/console/core/bean/AppControl.java | 6 ++++--
.../console/core/bean/MavenDependency.java | 6 ++++--
.../console/core/bean/MavenExclusion.java | 6 ++++--
.../streampark/console/core/bean/MavenPom.java | 6 ++++--
.../console/core/bean/ResponseResult.java | 6 ++++--
.../console/core/bean/RobotResponse.java | 6 ++++--
.../streampark/console/core/bean/SenderEmail.java | 6 ++++--
.../console/core/entity/AlertConfig.java | 6 ++++--
.../console/core/entity/AppBuildPipeline.java | 12 ++++++++----
.../console/core/entity/Application.java | 22 ++++------------------
.../console/core/entity/ApplicationBackUp.java | 6 ++++--
.../console/core/entity/ApplicationConfig.java | 6 ++++--
.../console/core/entity/ApplicationLog.java | 6 ++++--
.../streampark/console/core/entity/Effective.java | 6 ++++--
.../console/core/entity/ExternalLink.java | 6 ++++--
.../console/core/entity/FlinkCluster.java | 6 ++++--
.../streampark/console/core/entity/FlinkEnv.java | 6 ++++--
.../streampark/console/core/entity/FlinkSql.java | 6 ++++--
.../streampark/console/core/entity/Message.java | 6 ++++--
.../streampark/console/core/entity/Project.java | 6 ++++--
.../streampark/console/core/entity/SavePoint.java | 6 ++++--
.../streampark/console/core/entity/Setting.java | 6 ++++--
.../streampark/console/core/entity/Variable.java | 6 ++++--
.../streampark/console/core/entity/YarnQueue.java | 6 ++++--
.../console/core/metrics/flink/CheckPoints.java | 12 ++++++++----
.../console/core/metrics/flink/JobsOverview.java | 12 ++++++++----
.../console/core/metrics/flink/Overview.java | 6 ++++--
.../console/core/metrics/yarn/YarnAppInfo.java | 9 ++++++---
.../console/core/task/CheckpointProcessor.java | 6 ++++--
.../console/system/authentication/JWTToken.java | 6 ++++--
.../console/system/entity/AccessToken.java | 6 ++++--
.../streampark/console/system/entity/Member.java | 6 ++++--
.../streampark/console/system/entity/Menu.java | 6 ++++--
.../streampark/console/system/entity/Role.java | 6 ++++--
.../streampark/console/system/entity/RoleMenu.java | 6 ++++--
.../streampark/console/system/entity/SysLog.java | 6 ++++--
.../streampark/console/system/entity/Team.java | 6 ++++--
.../streampark/console/system/entity/User.java | 6 ++++--
52 files changed, 230 insertions(+), 131 deletions(-)
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/RestRequest.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/RestRequest.java
index 8d2eeeb2f..3ebfddb27 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/RestRequest.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/RestRequest.java
@@ -18,13 +18,15 @@
package org.apache.streampark.console.base.domain;
import io.swagger.v3.oas.annotations.media.Schema;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import org.springdoc.api.annotations.ParameterObject;
import java.io.Serializable;
@ParameterObject
-@Data
+@Getter
+@Setter
public class RestRequest implements Serializable {
private static final long serialVersionUID = -4869594085374385813L;
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/router/RouterMeta.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/router/RouterMeta.java
index 5753b6f64..5627bb6d7 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/router/RouterMeta.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/router/RouterMeta.java
@@ -19,12 +19,14 @@ package org.apache.streampark.console.base.domain.router;
import com.fasterxml.jackson.annotation.JsonInclude;
import lombok.AllArgsConstructor;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import java.io.Serializable;
/** Vue Router Meta */
-@Data
+@Getter
+@Setter
@AllArgsConstructor
@JsonInclude(JsonInclude.Include.NON_NULL)
public class RouterMeta implements Serializable {
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/router/RouterTree.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/router/RouterTree.java
index 4ef671e9b..c8f7428b7 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/router/RouterTree.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/router/RouterTree.java
@@ -20,13 +20,15 @@ package org.apache.streampark.console.base.domain.router;
import org.apache.streampark.console.system.entity.Menu;
import com.fasterxml.jackson.annotation.JsonInclude;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
-@Data
+@Getter
+@Setter
@JsonInclude(JsonInclude.Include.NON_NULL)
public class RouterTree<T> {
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/router/VueRouter.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/router/VueRouter.java
index 45688413c..15993efe9 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/router/VueRouter.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/router/VueRouter.java
@@ -19,14 +19,16 @@ package org.apache.streampark.console.base.domain.router;
import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.annotation.JsonInclude;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import java.io.Serializable;
import java.util.ArrayList;
import java.util.List;
/** Build Vue Router */
-@Data
+@Getter
+@Setter
@JsonInclude(JsonInclude.Include.NON_NULL)
public class VueRouter<T> implements Serializable {
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/properties/ShiroProperties.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/properties/ShiroProperties.java
index 4a9d9f42c..f8e2a129b 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/properties/ShiroProperties.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/properties/ShiroProperties.java
@@ -17,11 +17,13 @@
package org.apache.streampark.console.base.properties;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;
-@Data
+@Getter
+@Setter
@Configuration
@ConfigurationProperties(prefix = "streampark.shiro")
public class ShiroProperties {
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertConfigWithParams.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertConfigWithParams.java
index 634f99248..93e676bc9 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertConfigWithParams.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertConfigWithParams.java
@@ -24,14 +24,16 @@ import org.apache.commons.lang3.StringUtils;
import com.fasterxml.jackson.core.JsonProcessingException;
import io.swagger.v3.oas.annotations.media.Schema;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.BeanUtils;
import java.io.Serializable;
@Schema(name = "AlertConfig")
-@Data
+@Getter
+@Setter
@Slf4j
public class AlertConfigWithParams implements Serializable {
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertDingTalkParams.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertDingTalkParams.java
index d6bb14e41..cb70b031c 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertDingTalkParams.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertDingTalkParams.java
@@ -19,14 +19,16 @@ package org.apache.streampark.console.core.bean;
import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
import io.swagger.v3.oas.annotations.media.Schema;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import javax.validation.constraints.NotBlank;
import java.io.Serializable;
@Schema(name = "AlertDingTalk")
-@Data
+@Getter
+@Setter
@JsonIgnoreProperties(ignoreUnknown = true)
public class AlertDingTalkParams implements Serializable {
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertEmailParams.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertEmailParams.java
index b9e7ac89f..c83d05e66 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertEmailParams.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertEmailParams.java
@@ -19,14 +19,16 @@ package org.apache.streampark.console.core.bean;
import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
import io.swagger.v3.oas.annotations.media.Schema;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import javax.validation.constraints.NotBlank;
import java.io.Serializable;
@Schema(name = "AlertEmail")
-@Data
+@Getter
+@Setter
@JsonIgnoreProperties(ignoreUnknown = true)
public class AlertEmailParams implements Serializable {
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertHttpCallbackParams.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertHttpCallbackParams.java
index f95311717..b94cbf0aa 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertHttpCallbackParams.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertHttpCallbackParams.java
@@ -19,14 +19,16 @@ package org.apache.streampark.console.core.bean;
import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
import io.swagger.v3.oas.annotations.media.Schema;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import javax.validation.constraints.NotBlank;
import java.io.Serializable;
@Schema(name = "AlertHttpCallback")
-@Data
+@Getter
+@Setter
@JsonIgnoreProperties(ignoreUnknown = true)
public class AlertHttpCallbackParams implements Serializable {
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertLarkParams.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertLarkParams.java
index 01f55511b..e6f4fc64f 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertLarkParams.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertLarkParams.java
@@ -19,14 +19,16 @@ package org.apache.streampark.console.core.bean;
import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
import io.swagger.v3.oas.annotations.media.Schema;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import javax.validation.constraints.NotBlank;
import java.io.Serializable;
@Schema(name = "AlertLark")
-@Data
+@Getter
+@Setter
@JsonIgnoreProperties(ignoreUnknown = true)
public class AlertLarkParams implements Serializable {
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertLarkRobotResponse.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertLarkRobotResponse.java
index c779173dc..1bbbccc35 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertLarkRobotResponse.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertLarkRobotResponse.java
@@ -18,11 +18,13 @@
package org.apache.streampark.console.core.bean;
import com.fasterxml.jackson.annotation.JsonProperty;
-import lombok.Data;
+import lombok.Getter;
import lombok.NoArgsConstructor;
+import lombok.Setter;
@NoArgsConstructor
-@Data
+@Getter
+@Setter
public class AlertLarkRobotResponse {
@JsonProperty("Extra")
private Object extra;
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertTemplate.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertTemplate.java
index fa6487707..d1cd6df2b 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertTemplate.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertTemplate.java
@@ -24,13 +24,15 @@ import org.apache.streampark.console.core.entity.Application;
import org.apache.streampark.console.core.enums.CheckPointStatus;
import org.apache.streampark.console.core.enums.FlinkAppState;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import java.io.Serializable;
import java.util.Date;
import java.util.TimeZone;
-@Data
+@Getter
+@Setter
public class AlertTemplate implements Serializable {
private String title;
private String subject;
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertWeComParams.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertWeComParams.java
index 3568f3dd3..de8dced07 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertWeComParams.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertWeComParams.java
@@ -19,14 +19,16 @@ package org.apache.streampark.console.core.bean;
import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
import io.swagger.v3.oas.annotations.media.Schema;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import javax.validation.constraints.NotBlank;
import java.io.Serializable;
@Schema(name = "AlertWeCom")
-@Data
+@Getter
+@Setter
@JsonIgnoreProperties(ignoreUnknown = true)
public class AlertWeComParams implements Serializable {
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AppBuildDockerResolvedDetail.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AppBuildDockerResolvedDetail.java
index b05667a57..54d7559d9 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AppBuildDockerResolvedDetail.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AppBuildDockerResolvedDetail.java
@@ -22,7 +22,8 @@ import org.apache.streampark.flink.packer.pipeline.DockerPullSnapshot;
import org.apache.streampark.flink.packer.pipeline.DockerPushSnapshot;
import org.apache.streampark.flink.packer.pipeline.DockerResolvedSnapshot;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import lombok.experimental.Accessors;
import javax.annotation.Nullable;
@@ -33,7 +34,8 @@ import java.util.List;
import java.util.stream.Collectors;
/** View for DockerResolveProgress */
-@Data
+@Getter
+@Setter
@Accessors(chain = true)
public class AppBuildDockerResolvedDetail {
@@ -52,7 +54,8 @@ public class AppBuildDockerResolvedDetail {
.setPush(ImagePush.of(snapshot.push()));
}
- @Data
+ @Getter
+ @Setter
@Accessors(chain = true)
public static class ImagePull {
private List<ImageLayer> layers;
@@ -79,7 +82,8 @@ public class AppBuildDockerResolvedDetail {
}
}
- @Data
+ @Getter
+ @Setter
@Accessors(chain = true)
public static class ImageBuild {
private List<String> steps;
@@ -98,7 +102,8 @@ public class AppBuildDockerResolvedDetail {
}
}
- @Data
+ @Getter
+ @Setter
@Accessors(chain = true)
public static class ImagePush {
private List<ImageLayer> layers;
@@ -125,7 +130,8 @@ public class AppBuildDockerResolvedDetail {
}
}
- @Data
+ @Getter
+ @Setter
@Accessors(chain = true)
public static class ImageLayer {
private String layerId;
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AppControl.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AppControl.java
index 7bec42a41..f899ac653 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AppControl.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AppControl.java
@@ -17,10 +17,12 @@
package org.apache.streampark.console.core.bean;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import lombok.experimental.Accessors;
-@Data
+@Getter
+@Setter
@Accessors(chain = true)
public class AppControl {
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/MavenDependency.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/MavenDependency.java
index ec6bb14a8..3c1842f43 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/MavenDependency.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/MavenDependency.java
@@ -26,7 +26,8 @@ import org.apache.streampark.flink.packer.maven.MavenArtifact;
import org.apache.commons.lang3.StringUtils;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import lombok.SneakyThrows;
import java.io.File;
@@ -35,7 +36,8 @@ import java.util.List;
import java.util.Set;
import java.util.stream.Collectors;
-@Data
+@Getter
+@Setter
public class MavenDependency {
private Set<MavenPom> pom = Collections.emptySet();
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/MavenExclusion.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/MavenExclusion.java
index 9ab025f36..d821ac7dc 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/MavenExclusion.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/MavenExclusion.java
@@ -17,11 +17,13 @@
package org.apache.streampark.console.core.bean;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import java.util.Objects;
-@Data
+@Getter
+@Setter
public class MavenExclusion {
private String groupId;
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/MavenPom.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/MavenPom.java
index 21164061c..3c92d854b 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/MavenPom.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/MavenPom.java
@@ -19,14 +19,16 @@ package org.apache.streampark.console.core.bean;
import org.apache.commons.lang3.StringUtils;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import java.util.Collections;
import java.util.Objects;
import java.util.Set;
import java.util.stream.Collectors;
-@Data
+@Getter
+@Setter
public class MavenPom {
private String groupId;
private String artifactId;
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/ResponseResult.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/ResponseResult.java
index 86ea14e63..87f32f3e7 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/ResponseResult.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/ResponseResult.java
@@ -17,9 +17,11 @@
package org.apache.streampark.console.core.bean;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
-@Data
+@Getter
+@Setter
public class ResponseResult<T> {
private int status;
private String msg;
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/RobotResponse.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/RobotResponse.java
index fa23cb98b..f2338882d 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/RobotResponse.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/RobotResponse.java
@@ -17,10 +17,12 @@
package org.apache.streampark.console.core.bean;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
/** The robot alarm response of DingTalk And WeCom */
-@Data
+@Getter
+@Setter
public class RobotResponse {
private Integer errcode;
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/SenderEmail.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/SenderEmail.java
index f2d16ebf9..d248cb77f 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/SenderEmail.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/SenderEmail.java
@@ -17,9 +17,11 @@
package org.apache.streampark.console.core.bean;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
-@Data
+@Getter
+@Setter
public class SenderEmail {
private String smtpHost;
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/AlertConfig.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/AlertConfig.java
index 476f17511..7ac685311 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/AlertConfig.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/AlertConfig.java
@@ -24,14 +24,16 @@ import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.core.JsonProcessingException;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.BeanUtils;
import java.io.Serializable;
import java.util.Date;
-@Data
+@Getter
+@Setter
@TableName("t_alert_config")
@Slf4j
public class AlertConfig implements Serializable {
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/AppBuildPipeline.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/AppBuildPipeline.java
index fddcd80a2..6b4db8c6d 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/AppBuildPipeline.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/AppBuildPipeline.java
@@ -37,8 +37,9 @@ import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.core.type.TypeReference;
import lombok.AllArgsConstructor;
-import lombok.Data;
+import lombok.Getter;
import lombok.NoArgsConstructor;
+import lombok.Setter;
import lombok.experimental.Accessors;
import lombok.extern.slf4j.Slf4j;
@@ -58,7 +59,8 @@ import java.util.stream.Collectors;
* corresponding ApplicationBuildPipeline record.
*/
@TableName("t_app_build_pipe")
-@Data
+@Getter
+@Setter
@Accessors(chain = true)
@NoArgsConstructor
@AllArgsConstructor
@@ -272,7 +274,8 @@ public class AppBuildPipeline {
}
/** View object of AppBuildPipeline */
- @Data
+ @Getter
+ @Setter
@Accessors(chain = true)
@NoArgsConstructor
public static class View {
@@ -327,7 +330,8 @@ public class AppBuildPipeline {
}
}
- @Data
+ @Getter
+ @Setter
@Accessors(chain = true)
@NoArgsConstructor
public static class Step {
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Application.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Application.java
index 8560a28c9..ab2f69d33 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Application.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Application.java
@@ -45,7 +45,8 @@ import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.annotation.JsonIgnore;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
@@ -61,7 +62,8 @@ import java.util.Optional;
import static org.apache.streampark.console.core.enums.FlinkAppState.of;
-@Data
+@Getter
+@Setter
@TableName("t_flink_app")
@Slf4j
public class Application implements Serializable {
@@ -249,22 +251,6 @@ public class Application implements Serializable {
private transient AppControl appControl;
- public String getIngressTemplate() {
- return ingressTemplate;
- }
-
- public void setIngressTemplate(String ingressTemplate) {
- this.ingressTemplate = ingressTemplate;
- }
-
- public String getDefaultModeIngress() {
- return defaultModeIngress;
- }
-
- public void setDefaultModeIngress(String defaultModeIngress) {
- this.defaultModeIngress = defaultModeIngress;
- }
-
public void setK8sNamespace(String k8sNamespace) {
this.k8sNamespace =
StringUtils.isBlank(k8sNamespace)
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/ApplicationBackUp.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/ApplicationBackUp.java
index 9d966a125..50f89c626 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/ApplicationBackUp.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/ApplicationBackUp.java
@@ -22,12 +22,14 @@ import org.apache.streampark.common.conf.Workspace;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import lombok.extern.slf4j.Slf4j;
import java.util.Date;
-@Data
+@Getter
+@Setter
@TableName("t_app_backup")
@Slf4j
public class ApplicationBackUp {
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/ApplicationConfig.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/ApplicationConfig.java
index 5d9fba53d..abc5dabaa 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/ApplicationConfig.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/ApplicationConfig.java
@@ -27,7 +27,8 @@ import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import lombok.extern.slf4j.Slf4j;
import java.util.Base64;
@@ -36,7 +37,8 @@ import java.util.Date;
import java.util.Map;
import java.util.stream.Collectors;
-@Data
+@Getter
+@Setter
@TableName("t_flink_config")
@Slf4j
public class ApplicationConfig {
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/ApplicationLog.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/ApplicationLog.java
index ade3195f8..1c73181d2 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/ApplicationLog.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/ApplicationLog.java
@@ -20,12 +20,14 @@ package org.apache.streampark.console.core.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import lombok.extern.slf4j.Slf4j;
import java.util.Date;
-@Data
+@Getter
+@Setter
@TableName("t_flink_log")
@Slf4j
public class ApplicationLog {
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Effective.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Effective.java
index 35613076d..dd527566a 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Effective.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Effective.java
@@ -22,12 +22,14 @@ import org.apache.streampark.console.core.enums.EffectiveType;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import lombok.extern.slf4j.Slf4j;
import java.util.Date;
-@Data
+@Getter
+@Setter
@TableName("t_flink_effective")
@Slf4j
public class Effective {
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/ExternalLink.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/ExternalLink.java
index 2584b4fd8..fa74f3b1e 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/ExternalLink.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/ExternalLink.java
@@ -21,14 +21,16 @@ import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import javax.validation.constraints.NotBlank;
import java.io.Serializable;
import java.util.Date;
-@Data
+@Getter
+@Setter
@TableName("t_external_link")
public class ExternalLink implements Serializable {
@TableId(type = IdType.AUTO)
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkCluster.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkCluster.java
index dfc3985f2..c16403419 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkCluster.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkCluster.java
@@ -42,7 +42,8 @@ import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.core.type.TypeReference;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import lombok.SneakyThrows;
import java.io.Serializable;
@@ -53,7 +54,8 @@ import java.util.HashMap;
import java.util.List;
import java.util.Map;
-@Data
+@Getter
+@Setter
@TableName("t_flink_cluster")
public class FlinkCluster implements Serializable {
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkEnv.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkEnv.java
index 60db28315..f9aefa9bd 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkEnv.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkEnv.java
@@ -28,14 +28,16 @@ import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.annotation.JsonIgnore;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import java.io.File;
import java.io.Serializable;
import java.util.Date;
import java.util.Map;
-@Data
+@Getter
+@Setter
@TableName("t_flink_env")
public class FlinkEnv implements Serializable {
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkSql.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkSql.java
index d944e14f8..c0ca2fbd6 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkSql.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkSql.java
@@ -25,12 +25,14 @@ import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import java.util.Base64;
import java.util.Date;
-@Data
+@Getter
+@Setter
@TableName("t_flink_sql")
public class FlinkSql {
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Message.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Message.java
index ce0087637..1179f9ab6 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Message.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Message.java
@@ -22,11 +22,13 @@ import org.apache.streampark.console.core.enums.NoticeType;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import java.util.Date;
-@Data
+@Getter
+@Setter
@TableName("t_message")
public class Message {
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Project.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Project.java
index 0a380cb46..03e8c561b 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Project.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Project.java
@@ -36,7 +36,8 @@ import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.annotation.JsonIgnore;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import lombok.extern.slf4j.Slf4j;
import org.eclipse.jgit.lib.Constants;
@@ -51,7 +52,8 @@ import java.util.regex.Matcher;
import java.util.regex.Pattern;
@Slf4j
-@Data
+@Getter
+@Setter
@TableName("t_flink_project")
public class Project implements Serializable {
@TableId(type = IdType.AUTO)
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/SavePoint.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/SavePoint.java
index a8fd091a1..79a4e3871 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/SavePoint.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/SavePoint.java
@@ -20,12 +20,14 @@ package org.apache.streampark.console.core.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import lombok.extern.slf4j.Slf4j;
import java.util.Date;
-@Data
+@Getter
+@Setter
@TableName("t_flink_savepoint")
@Slf4j
public class SavePoint {
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Setting.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Setting.java
index edd8659d4..02c2a6e6f 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Setting.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Setting.java
@@ -22,12 +22,14 @@ import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import lombok.extern.slf4j.Slf4j;
import java.io.Serializable;
-@Data
+@Getter
+@Setter
@TableName("t_setting")
@Slf4j
public class Setting implements Serializable {
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Variable.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Variable.java
index f9e225b17..73255f7be 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Variable.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Variable.java
@@ -22,7 +22,8 @@ import org.apache.streampark.common.conf.ConfigConst;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import javax.validation.constraints.NotBlank;
import javax.validation.constraints.NotNull;
@@ -31,7 +32,8 @@ import javax.validation.constraints.Size;
import java.io.Serializable;
import java.util.Date;
-@Data
+@Getter
+@Setter
@TableName("t_variable")
public class Variable implements Serializable {
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/YarnQueue.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/YarnQueue.java
index f123fdafe..c4228ed37 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/YarnQueue.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/YarnQueue.java
@@ -23,12 +23,14 @@ import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import java.io.Serializable;
import java.util.Date;
-@Data
+@Getter
+@Setter
@TableName("t_yarn_queue")
public class YarnQueue implements Serializable {
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/metrics/flink/CheckPoints.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/metrics/flink/CheckPoints.java
index b92fc4059..f96ed5282 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/metrics/flink/CheckPoints.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/metrics/flink/CheckPoints.java
@@ -22,7 +22,8 @@ import org.apache.streampark.console.core.enums.CheckPointType;
import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.annotation.JsonProperty;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import java.io.Serializable;
import java.util.ArrayList;
@@ -30,7 +31,8 @@ import java.util.Collections;
import java.util.List;
import java.util.Objects;
-@Data
+@Getter
+@Setter
public class CheckPoints implements Serializable {
private List<CheckPoint> history;
@@ -45,7 +47,8 @@ public class CheckPoints implements Serializable {
return latest.getLatestCheckpoint();
}
- @Data
+ @Getter
+ @Setter
public static class CheckPoint implements Serializable {
private Long id;
private String status;
@@ -91,7 +94,8 @@ public class CheckPoints implements Serializable {
}
}
- @Data
+ @Getter
+ @Setter
public static class Latest implements Serializable {
private CheckPoint completed;
private CheckPoint savepoint;
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/metrics/flink/JobsOverview.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/metrics/flink/JobsOverview.java
index 310378f69..b8c1c0d30 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/metrics/flink/JobsOverview.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/metrics/flink/JobsOverview.java
@@ -18,17 +18,20 @@
package org.apache.streampark.console.core.metrics.flink;
import com.fasterxml.jackson.annotation.JsonProperty;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import java.io.Serializable;
import java.util.List;
-@Data
+@Getter
+@Setter
public class JobsOverview implements Serializable {
private List<Job> jobs;
- @Data
+ @Getter
+ @Setter
public static class Job implements Serializable {
@JsonProperty("jid")
private String id;
@@ -50,7 +53,8 @@ public class JobsOverview implements Serializable {
private Task tasks;
}
- @Data
+ @Getter
+ @Setter
public static class Task implements Serializable {
private int total;
private int created;
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/metrics/flink/Overview.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/metrics/flink/Overview.java
index d879cfa51..1608f23fb 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/metrics/flink/Overview.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/metrics/flink/Overview.java
@@ -18,9 +18,11 @@
package org.apache.streampark.console.core.metrics.flink;
import com.fasterxml.jackson.annotation.JsonProperty;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
-@Data
+@Getter
+@Setter
public class Overview {
private Integer taskmanagers;
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/metrics/yarn/YarnAppInfo.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/metrics/yarn/YarnAppInfo.java
index 1c769448b..8e721fce2 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/metrics/yarn/YarnAppInfo.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/metrics/yarn/YarnAppInfo.java
@@ -18,14 +18,17 @@
package org.apache.streampark.console.core.metrics.yarn;
import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
-@Data
+@Getter
+@Setter
public class YarnAppInfo {
private App app;
- @Data
+ @Getter
+ @Setter
@JsonIgnoreProperties(ignoreUnknown = true)
public static class App {
private String id;
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/task/CheckpointProcessor.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/task/CheckpointProcessor.java
index f96217b92..42b1a4137 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/task/CheckpointProcessor.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/task/CheckpointProcessor.java
@@ -28,7 +28,8 @@ import org.apache.streampark.console.core.service.alert.AlertService;
import com.github.benmanes.caffeine.cache.Cache;
import com.github.benmanes.caffeine.cache.Caffeine;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
@@ -199,7 +200,8 @@ public class CheckpointProcessor {
}
/** Util class for checkpoint key. */
- @Data
+ @Getter
+ @Setter
public static class CheckPointKey {
private Long appId;
private String jobId;
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/authentication/JWTToken.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/authentication/JWTToken.java
index b035253f2..e83b7c1db 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/authentication/JWTToken.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/authentication/JWTToken.java
@@ -19,10 +19,12 @@ package org.apache.streampark.console.system.authentication;
import org.apache.shiro.authc.AuthenticationToken;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
/** JSON Web Token */
-@Data
+@Getter
+@Setter
public class JWTToken implements AuthenticationToken {
private static final long serialVersionUID = 1282057025599826155L;
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/AccessToken.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/AccessToken.java
index cc89f609d..f663ec9ec 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/AccessToken.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/AccessToken.java
@@ -20,7 +20,8 @@ package org.apache.streampark.console.system.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import javax.validation.constraints.NotBlank;
import javax.validation.constraints.NotNull;
@@ -28,7 +29,8 @@ import javax.validation.constraints.NotNull;
import java.io.Serializable;
import java.util.Date;
-@Data
+@Getter
+@Setter
@TableName("t_access_token")
public class AccessToken implements Serializable {
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/Member.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/Member.java
index 422b77a2b..2292c15ca 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/Member.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/Member.java
@@ -20,13 +20,15 @@ package org.apache.streampark.console.system.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import java.io.Serializable;
import java.util.Date;
@TableName("t_member")
-@Data
+@Getter
+@Setter
public class Member implements Serializable {
private static final long serialVersionUID = -3166012934498268403L;
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/Menu.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/Menu.java
index 61533daa2..b32fb7f9e 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/Menu.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/Menu.java
@@ -20,7 +20,8 @@ package org.apache.streampark.console.system.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import javax.validation.constraints.NotBlank;
import javax.validation.constraints.Size;
@@ -28,7 +29,8 @@ import javax.validation.constraints.Size;
import java.io.Serializable;
import java.util.Date;
-@Data
+@Getter
+@Setter
@TableName("t_menu")
public class Menu implements Serializable {
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/Role.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/Role.java
index fc61c63e4..a5bceb83d 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/Role.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/Role.java
@@ -20,7 +20,8 @@ package org.apache.streampark.console.system.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import javax.validation.constraints.NotBlank;
import javax.validation.constraints.Size;
@@ -28,7 +29,8 @@ import javax.validation.constraints.Size;
import java.io.Serializable;
import java.util.Date;
-@Data
+@Getter
+@Setter
@TableName("t_role")
public class Role implements Serializable {
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/RoleMenu.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/RoleMenu.java
index e2f28c6b2..fc351c010 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/RoleMenu.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/RoleMenu.java
@@ -20,12 +20,14 @@ package org.apache.streampark.console.system.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import java.io.Serializable;
@TableName("t_role_menu")
-@Data
+@Getter
+@Setter
public class RoleMenu implements Serializable {
private static final long serialVersionUID = -7573904024872252113L;
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/SysLog.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/SysLog.java
index cdfd51572..f02b21a8b 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/SysLog.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/SysLog.java
@@ -20,12 +20,14 @@ package org.apache.streampark.console.system.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import java.io.Serializable;
import java.util.Date;
-@Data
+@Getter
+@Setter
@TableName("t_log")
public class SysLog implements Serializable {
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/Team.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/Team.java
index 66db7b0c1..87d41fe02 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/Team.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/Team.java
@@ -20,14 +20,16 @@ package org.apache.streampark.console.system.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import javax.validation.constraints.Size;
import java.io.Serializable;
import java.util.Date;
-@Data
+@Getter
+@Setter
@TableName("t_team")
public class Team implements Serializable {
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/User.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/User.java
index 8d22c9823..9c2e03f99 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/User.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/User.java
@@ -24,7 +24,8 @@ import org.apache.streampark.console.core.enums.UserType;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
import javax.validation.constraints.Email;
import javax.validation.constraints.NotBlank;
@@ -33,7 +34,8 @@ import javax.validation.constraints.Size;
import java.io.Serializable;
import java.util.Date;
-@Data
+@Getter
+@Setter
@TableName("t_user")
public class User implements Serializable {