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 b537c1f86 [Bug] When calling Application using an interface, it is not
possible to recover from the latest CheckPoint or SavePoint (#3473)
b537c1f86 is described below
commit b537c1f86d44a5fbc54793b33cba2f2ffb9c478a
Author: onlookerr <[email protected]>
AuthorDate: Tue Jan 9 20:39:40 2024 +0800
[Bug] When calling Application using an interface, it is not possible to
recover from the latest CheckPoint or SavePoint (#3473)
* [Bug] When calling Application using an interface, it is not possible to
recover from the latest CheckPoint or SavePoint
* Update ApplicationActionServiceImpl.java
---------
Co-authored-by: benjobs <[email protected]>
---
.../core/service/application/impl/ApplicationActionServiceImpl.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/ApplicationActionServiceImpl.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/ApplicationActionServiceImpl.java
index 86384bab2..54fc3ec67 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/ApplicationActionServiceImpl.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/ApplicationActionServiceImpl.java
@@ -803,7 +803,7 @@ public class ApplicationActionServiceImpl extends
ServiceImpl<ApplicationMapper,
private String getSavePointed(Application appParam) {
if (appParam.getSavePointed()) {
- if (appParam.getSavePoint() == null) {
+ if (StringUtils.isBlank(appParam.getSavePoint())) {
SavePoint savePoint = savePointService.getLatest(appParam.getId());
if (savePoint != null) {
return savePoint.getPath();
