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 aac6290f0 [Improve] Use StringUtils.isNotBlank instead of
StringUtils.isNotEmpty (#3427)
aac6290f0 is described below
commit aac6290f0fa940e83e14cdbf76204599f4f91351
Author: zuo <[email protected]>
AuthorDate: Mon Dec 25 22:04:12 2023 +0800
[Improve] Use StringUtils.isNotBlank instead of StringUtils.isNotEmpty
(#3427)
---
.../main/java/org/apache/streampark/console/core/entity/Project.java | 2 +-
.../streampark/console/core/service/impl/SavePointServiceImpl.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
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 3ccbdac92..653405ba0 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
@@ -284,7 +284,7 @@ public class Project implements Serializable {
@JsonIgnore
public String getMavenWorkHome() {
String buildHome = this.getAppSource().getAbsolutePath();
- if (StringUtils.isNotEmpty(this.getPom())) {
+ if (StringUtils.isNotBlank(this.getPom())) {
buildHome =
new
File(buildHome.concat("/").concat(this.getPom())).getParentFile().getAbsolutePath();
}
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 59f894889..6d71af900 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
@@ -202,7 +202,7 @@ public class SavePointServiceImpl extends
ServiceImpl<SavePointMapper, SavePoint
public Boolean remove(Long id, Application appParam) throws
InternalException {
SavePoint savePoint = getById(id);
try {
- if (StringUtils.isNotEmpty(savePoint.getPath())) {
+ if (StringUtils.isNotBlank(savePoint.getPath())) {
appParam.getFsOperator().delete(savePoint.getPath());
}
return removeById(id);