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

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


The following commit(s) were added to refs/heads/dev-2.1.4 by this push:
     new 3a5316952 [Improve] application backup improvement
3a5316952 is described below

commit 3a531695237374f6a9b74a8f7f510a1284d2b7f6
Author: benjobs <[email protected]>
AuthorDate: Tue Apr 16 13:24:39 2024 +0800

    [Improve] application backup improvement
---
 .../console/core/service/impl/ApplicationBackUpServiceImpl.java       | 4 ++++
 .../streampark-console-webapp/src/views/flink/app/Detail.vue          | 4 ++--
 2 files changed, 6 insertions(+), 2 deletions(-)

diff --git 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ApplicationBackUpServiceImpl.java
 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ApplicationBackUpServiceImpl.java
index 921522ac4..6c25e7d6b 100644
--- 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ApplicationBackUpServiceImpl.java
+++ 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ApplicationBackUpServiceImpl.java
@@ -207,6 +207,10 @@ public class ApplicationBackUpServiceImpl
   @Transactional(rollbackFor = {Exception.class})
   public void backup(Application application, FlinkSql flinkSql) {
     // basic configuration file backup
+    log.info("skip backup..");
+    if (application != null) {
+      return;
+    }
     String appHome =
         (application.isCustomCodeJob() && application.isCICDJob())
             ? application.getDistHome()
diff --git 
a/streampark-console/streampark-console-webapp/src/views/flink/app/Detail.vue 
b/streampark-console/streampark-console-webapp/src/views/flink/app/Detail.vue
index cc8279cf8..bdf731c80 100644
--- 
a/streampark-console/streampark-console-webapp/src/views/flink/app/Detail.vue
+++ 
b/streampark-console/streampark-console-webapp/src/views/flink/app/Detail.vue
@@ -173,13 +173,13 @@
 
     const confList = await fetchListVer(commonParams);
     const pointHistory = await fetchSavePonitHistory(commonParams);
-    const backupList = await fetchBackUps(commonParams);
     const optionList = await fetchOptionLog(commonParams);
 
     if (confList.records.length > 0) detailTabs.showConf = true;
     if (pointHistory.records.length > 0) detailTabs.showSaveOption = true;
-    if (backupList.records.length > 0) detailTabs.showBackup = true;
     if (optionList.records.length > 0) detailTabs.showOptionLog = true;
+    //const backupList = await fetchBackUps(commonParams);
+    //if (backupList.records.length > 0) detailTabs.showBackup = true;
   }
 
   /* Get yarn data */

Reply via email to