| commit | b537c1f86d44a5fbc54793b33cba2f2ffb9c478a | [log] [tgz] |
|---|---|---|
| author | onlookerr <53333630+onlookerr@users.noreply.github.com> | Tue Jan 09 20:39:40 2024 +0800 |
| committer | GitHub <noreply@github.com> | Tue Jan 09 20:39:40 2024 +0800 |
| tree | 0547eeb4e7281e06cec9598efdac5cc621e2589d | |
| parent | c3699a647394db346239311efb81465d11c06103 [diff] |
[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 <benjobs@apache.org>
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 86384ba..54fc3ec 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 @@ 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();