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 dd4ecf272 [Improve] bump mybatis-plus to 3.5.3.1 (#2666)
dd4ecf272 is described below
commit dd4ecf2727cea17267fb235d663d5b70b7956838
Author: zhoulii <[email protected]>
AuthorDate: Thu Apr 20 15:24:31 2023 +0800
[Improve] bump mybatis-plus to 3.5.3.1 (#2666)
Co-authored-by: zhoulii <[email protected]>
---
streampark-console/streampark-console-service/pom.xml | 2 +-
.../streampark/console/core/service/impl/SavePointServiceImpl.java | 4 ++--
.../org/apache/streampark/console/core/task/CheckpointProcessor.java | 2 +-
3 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/streampark-console/streampark-console-service/pom.xml
b/streampark-console/streampark-console-service/pom.xml
index 288028831..a1d2648b5 100644
--- a/streampark-console/streampark-console-service/pom.xml
+++ b/streampark-console/streampark-console-service/pom.xml
@@ -34,7 +34,7 @@
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<postgresql.version>42.5.1</postgresql.version>
- <mybatis-plus.version>3.5.2</mybatis-plus.version>
+ <mybatis-plus.version>3.5.3.1</mybatis-plus.version>
<streampark.flink.shims.version>1.14</streampark.flink.shims.version>
<frontend.project.name>streampark-console-webapp</frontend.project.name>
<PermGen>64m</PermGen>
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SavePointServiceImpl.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SavePointServiceImpl.java
index 6c91e3bda..843a34850 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SavePointServiceImpl.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SavePointServiceImpl.java
@@ -59,12 +59,12 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import lombok.extern.slf4j.Slf4j;
-import org.jetbrains.annotations.NotNull;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
+import javax.annotation.Nonnull;
import javax.annotation.Nullable;
import java.net.URI;
@@ -370,7 +370,7 @@ public class SavePointServiceImpl extends
ServiceImpl<SavePointMapper, SavePoint
return result;
}
- @NotNull
+ @Nonnull
private Map<String, Object> tryGetRestProps(Application application,
FlinkCluster cluster) {
Map<String, Object> properties = new HashMap<>();
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 a1cb65fe6..f96217b92 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
@@ -29,11 +29,11 @@ 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 org.jetbrains.annotations.Nullable;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import javax.annotation.Nonnull;
+import javax.annotation.Nullable;
import java.util.Date;
import java.util.Map;