(streampark) branch dev-2.1.6 updated: [Bug] trigger savepoint with path bug fixed

[benjobs]

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

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


The following commit(s) were added to refs/heads/dev-2.1.6 by this push:
     new 171a19796 [Bug] trigger savepoint with path bug fixed
171a19796 is described below

commit 171a19796d2c7260404e804726883922c3c18c97
Author: benjobs <benj...@apache.org>
AuthorDate: Thu Apr 10 15:50:15 2025 +0800

    [Bug] trigger savepoint with path bug fixed
---
 .../streampark/console/core/service/impl/ApplicationServiceImpl.java | 2 +-
 .../streampark/console/core/service/impl/SavepointServiceImpl.java   | 5 +++--
 2 files changed, 4 insertions(+), 3 deletions(-)

diff --git 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ApplicationServiceImpl.java
 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ApplicationServiceImpl.java
index 3d6823174..3dc870365 100644
--- 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ApplicationServiceImpl.java
+++ 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ApplicationServiceImpl.java
@@ -1341,7 +1341,7 @@ public class ApplicationServiceImpl extends 
ServiceImpl<ApplicationMapper, Appli
         customSavepoint = savepointService.getSavePointPath(appParam);
       }
       if (StringUtils.isBlank(customSavepoint)
-          || application.getExecutionModeEnum() == 
ExecutionMode.YARN_APPLICATION) {
+          && ExecutionMode.isYarnMode(application.getExecutionMode())) {
         customSavepoint = Workspace.remote().APP_SAVEPOINTS();
       }
       if (StringUtils.isNotBlank(customSavepoint)) {
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 449676fdb..befeda433 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
@@ -421,10 +421,11 @@ public class SavepointServiceImpl extends 
ServiceImpl<SavepointMapper, Savepoint
     if (StringUtils.isBlank(savepointPath)) {
       result = this.getSavePointPath(application);
     }
-    if (StringUtils.isBlank(result)
-        || application.getExecutionModeEnum() == 
ExecutionMode.YARN_APPLICATION) {
+
+    if (StringUtils.isBlank(result) && 
ExecutionMode.isYarnMode(application.getExecutionMode())) {
       result = Workspace.remote().APP_SAVEPOINTS();
     }
+
     if (StringUtils.isNotBlank(result)) {
       processPath(result, application.getJobName(), application.getId());
     } else {