(incubator-streampark) branch dev-2.1.3 updated: [Feature] Trigger method add savepoint save (#3493)

[benjobs]

This is an automated email from the ASF dual-hosted git repository.

benjobs pushed a commit to branch dev-2.1.3
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git


The following commit(s) were added to refs/heads/dev-2.1.3 by this push:
     new 596485664 [Feature] Trigger method add savepoint save (#3493)
596485664 is described below

commit 596485664a4be32c5920cc58a18c3a8c57aa2cb8
Author: zero <164434...@qq.com>
AuthorDate: Wed Jan 24 09:18:52 2024 +0800

    [Feature] Trigger method add savepoint save (#3493)
    
    * trigger method add savepoint save
    
    * opt code
    
    * bug fix
    
    ---------
    
    Co-authored-by: weiye.gong <weiye.g...@garena.com>
---
 .../console/core/service/impl/SavePointServiceImpl.java        | 10 ++++++++++
 1 file changed, 10 insertions(+)

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 85b051e57..8dde05c8b 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
@@ -333,6 +333,16 @@ public class SavePointServiceImpl extends 
ServiceImpl<SavePointMapper, SavePoint
               if (savepointResponse != null && 
savepointResponse.savePointDir() != null) {
                 applicationLog.setSuccess(true);
                 String savePointDir = savepointResponse.savePointDir();
+
+                SavePoint savePoint = new SavePoint();
+                savePoint.setAppId(application.getId());
+                savePoint.setLatest(true);
+                savePoint.setType(CheckPointType.SAVEPOINT.get());
+                savePoint.setCreateTime(new Date());
+                savePoint.setTriggerTime(new Date());
+                savePoint.setPath(savePointDir);
+                this.save(savePoint);
+
                 log.info("Request savepoint successful, savepointDir: {}", 
savePointDir);
               }
             },