(streampark) branch dev updated: [Fix] Manually trigger savepoint and save after success (#4280)

[benjobs]

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/streampark.git


The following commit(s) were added to refs/heads/dev by this push:
     new 5701956a2 [Fix] Manually trigger savepoint and save after success 
(#4280)
5701956a2 is described below

commit 5701956a2a1f4558f9684fe0df542d6197a6998a
Author: CuteShaos <57027034+cutesh...@users.noreply.github.com>
AuthorDate: Sun Aug 31 11:52:59 2025 +0800

    [Fix] Manually trigger savepoint and save after success (#4280)
---
 .../console/core/service/impl/FlinkSavepointServiceImpl.java  | 11 +++++++++++
 1 file changed, 11 insertions(+)

diff --git 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkSavepointServiceImpl.java
 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkSavepointServiceImpl.java
index 8f2ab73cb..743cbe615 100644
--- 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkSavepointServiceImpl.java
+++ 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkSavepointServiceImpl.java
@@ -238,6 +238,7 @@ public class FlinkSavepointServiceImpl extends 
ServiceImpl<FlinkSavepointMapper,
                                                FlinkApplication application,
                                                ApplicationLog applicationLog,
                                                
CompletableFuture<SavepointResponse> savepointFuture) {
+        final Date triggerTime = new Date();
         CompletableFutureUtils.runTimeout(
             savepointFuture,
             10L,
@@ -246,6 +247,16 @@ public class FlinkSavepointServiceImpl extends 
ServiceImpl<FlinkSavepointMapper,
                 if (savepointResponse != null && 
savepointResponse.savepointDir() != null) {
                     applicationLog.setSuccess(true);
                     String savepointDir = savepointResponse.savepointDir();
+
+                    // savepoint successfully add saved
+                    FlinkSavepoint savepoint = new FlinkSavepoint();
+                    savepoint.setAppId(application.getId());
+                    savepoint.setLatest(true);
+                    savepoint.setType(CheckPointTypeEnum.SAVEPOINT.get());
+                    savepoint.setPath(savepointDir);
+                    savepoint.setTriggerTime(triggerTime);
+                    savepoint.setCreateTime(new Date());
+                    save(savepoint);
                     log.info("Request savepoint successful, savepointDir: {}", 
savepointDir);
                 }
             },