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 7534584040..8ddae2715c 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 @@ -30,10 +30,10 @@ public class RestRequest implements Serializable { private static final long serialVersionUID = 1L; @Schema(example = "10", required = true) - private int pageSize = 10; + private Integer pageSize = 10; @Schema(example = "1", required = true) - private int pageNum = 1; + private Integer pageNum = 1; @Schema(example = "", description = "e.g. create_time") private String sortField; 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 4ef671e9bc..a81017e22d 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 @@ -46,7 +46,7 @@ public class RouterTree { private String type; - private boolean display; + private Boolean display; private Double order; @@ -58,9 +58,9 @@ public class RouterTree { private String parentId; - private boolean hasParent = false; + private Boolean hasParent = false; - private boolean hasChildren = false; + private Boolean hasChildren = false; private Date createTime; 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 da3dffd041..f16b62e13d 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 @@ -48,9 +48,9 @@ public class VueRouter implements Serializable { private List> children; - @JsonIgnore private boolean hasParent = false; + @JsonIgnore private Boolean hasParent = false; - @JsonIgnore private boolean hasChildren = false; + @JsonIgnore private Boolean hasChildren = false; public void initChildren() { this.children = new ArrayList<>(); 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 e96b315839..2a24ddae89 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 @@ -48,7 +48,7 @@ public class AlertTemplate implements Serializable { private Boolean restart; private Integer restartIndex; private Integer totalRestart; - private boolean atAll = false; + private Boolean atAll = false; private Integer allJobs; private Integer affectedJobs; private String user; 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 7bec42a419..bb24bc8196 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 @@ -25,11 +25,11 @@ public class AppControl { /** allow to start the application */ - private boolean allowStart; + private Boolean allowStart; /** allow to stop the application */ - private boolean allowStop; + private Boolean allowStop; /** allow to build the application */ - private boolean allowBuild; + private Boolean allowBuild; } diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/EmailConfig.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/EmailConfig.java index f631f12691..76860396ee 100644 --- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/EmailConfig.java +++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/EmailConfig.java @@ -38,7 +38,7 @@ public class EmailConfig { private String from; private String userName; private String password; - private boolean ssl; + private Boolean ssl; /** * Constructs the EmailConfig object from the given settings map. 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 86ea14e639..b6824c0e4f 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 @@ -21,7 +21,7 @@ @Data public class ResponseResult { - private int status; + private Integer status; private String msg; private T result; } 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 8dc4278340..91bd26d047 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 @@ -55,11 +55,11 @@ public class FlinkSql { private Integer candidate; private Date createTime; - private transient boolean effective = false; + private transient Boolean effective = false; /** sql diff */ - private transient boolean sqlDifference = false; + private transient Boolean sqlDifference = false; /** dependency diff */ - private transient boolean dependencyDifference = false; + private transient Boolean dependencyDifference = false; public FlinkSql() {} 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 edd8659d44..7774a3e8df 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 @@ -45,8 +45,8 @@ public class Setting implements Serializable { private Integer type; private String description; - private transient boolean editable = false; - private transient boolean submitting = false; + private transient Boolean editable = false; + private transient Boolean submitting = false; private transient String flinkHome; private transient String flinkConf;