Skip to content

Commit 5701956

Browse files
authored
[Fix] Manually trigger savepoint and save after success (#4280)
1 parent 0a12915 commit 5701956

File tree

1 file changed

+11
-0
lines changed

1 file changed

+11
-0
lines changed

streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkSavepointServiceImpl.java

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -238,6 +238,7 @@ private void handleSavepointResponseFuture(
238238
FlinkApplication application,
239239
ApplicationLog applicationLog,
240240
CompletableFuture<SavepointResponse> savepointFuture) {
241+
final Date triggerTime = new Date();
241242
CompletableFutureUtils.runTimeout(
242243
savepointFuture,
243244
10L,
@@ -246,6 +247,16 @@ private void handleSavepointResponseFuture(
246247
if (savepointResponse != null && savepointResponse.savepointDir() != null) {
247248
applicationLog.setSuccess(true);
248249
String savepointDir = savepointResponse.savepointDir();
250+
251+
// savepoint successfully add saved
252+
FlinkSavepoint savepoint = new FlinkSavepoint();
253+
savepoint.setAppId(application.getId());
254+
savepoint.setLatest(true);
255+
savepoint.setType(CheckPointTypeEnum.SAVEPOINT.get());
256+
savepoint.setPath(savepointDir);
257+
savepoint.setTriggerTime(triggerTime);
258+
savepoint.setCreateTime(new Date());
259+
save(savepoint);
249260
log.info("Request savepoint successful, savepointDir: {}", savepointDir);
250261
}
251262
},

0 commit comments

Comments
 (0)