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 2799d5be3 [Improve] mybatis-plus update improvements
2799d5be3 is described below
commit 2799d5be3ae445df7974bdc485fc0f069627b7b0
Author: benjobs <[email protected]>
AuthorDate: Tue Mar 5 21:02:52 2024 +0800
[Improve] mybatis-plus update improvements
---
.../streampark/console/core/entity/Application.java | 16 ++++++++++++++--
1 file changed, 14 insertions(+), 2 deletions(-)
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 c6c30fd73..cda37c306 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
@@ -126,18 +126,24 @@ public class Application implements Serializable {
@TableField(updateStrategy = FieldStrategy.IGNORED)
private Integer alertId;
+ @TableField(updateStrategy = FieldStrategy.IGNORED)
private String args;
/** application module */
private String module;
+ @TableField(updateStrategy = FieldStrategy.IGNORED)
private String options;
@TableField(updateStrategy = FieldStrategy.IGNORED)
private String hotParams;
private Integer resolveOrder;
+
private Integer executionMode;
+
+ @TableField(updateStrategy = FieldStrategy.IGNORED)
private String dynamicProperties;
+
private Integer appType;
/** determine if tracking status */
@@ -165,12 +171,15 @@ public class Application implements Serializable {
private Long duration;
/** checkpoint max failure interval */
+ @TableField(updateStrategy = FieldStrategy.IGNORED)
private Integer cpMaxFailureInterval;
/** checkpoint failure rate interval */
+ @TableField(updateStrategy = FieldStrategy.IGNORED)
private Integer cpFailureRateInterval;
/** Actions triggered after X minutes failed Y times: 1: send alert 2:
restart */
+ @TableField(updateStrategy = FieldStrategy.IGNORED)
private Integer cpFailureAction;
/** overview */
@@ -187,8 +196,6 @@ public class Application implements Serializable {
@TableField(updateStrategy = FieldStrategy.IGNORED)
private Long flinkClusterId;
- private String description;
-
private Date createTime;
private Date optionTime;
@@ -204,6 +211,7 @@ public class Application implements Serializable {
private String k8sTmPodTemplate;
private String ingressTemplate;
+
private String defaultModeIngress;
/** 1: cicd (build from csv) 2: upload (upload local jar job) */
@@ -212,8 +220,12 @@ public class Application implements Serializable {
/** flink-hadoop integration on flink-k8s mode */
private Boolean k8sHadoopIntegration;
+ @TableField(updateStrategy = FieldStrategy.IGNORED)
private String tags;
+ @TableField(updateStrategy = FieldStrategy.IGNORED)
+ private String description;
+
/** running job */
private transient JobsOverview.Task overview;