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 */