From 91fbede5aa117b3c010e9cbb8804df90757dbe5c Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期一, 27 四月 2026 13:32:13 +0800
Subject: [PATCH] fix: isolate auto tune cache refresh failures
---
src/main/java/com/zy/ai/service/impl/AutoTuneApplyServiceImpl.java | 18 +++++++++++++-----
1 files changed, 13 insertions(+), 5 deletions(-)
diff --git a/src/main/java/com/zy/ai/service/impl/AutoTuneApplyServiceImpl.java b/src/main/java/com/zy/ai/service/impl/AutoTuneApplyServiceImpl.java
index 12b5e4c..eca3fbd 100644
--- a/src/main/java/com/zy/ai/service/impl/AutoTuneApplyServiceImpl.java
+++ b/src/main/java/com/zy/ai/service/impl/AutoTuneApplyServiceImpl.java
@@ -141,7 +141,7 @@
now,
true
);
- refreshSystemConfigCacheIfNeeded(persistenceResult);
+ refreshSystemConfigCacheSafely(persistenceResult);
return buildResult(job, persistenceResult.getAuditChanges(), false);
} catch (RuntimeException exception) {
markWriteFailure(validatedChanges, exception);
@@ -216,7 +216,7 @@
sourceChanges,
now
);
- refreshRollbackConfigCacheIfNeeded(persistenceResult);
+ refreshRollbackConfigCacheSafely(persistenceResult);
return buildResult(rollbackJob, persistenceResult.getRollbackChanges(), false);
} catch (RuntimeException exception) {
Date failureNow = new Date();
@@ -484,9 +484,9 @@
}
}
- private void refreshSystemConfigCacheIfNeeded(ApplyPersistenceResult persistenceResult) {
+ private void refreshSystemConfigCacheSafely(ApplyPersistenceResult persistenceResult) {
if (persistenceResult != null && persistenceResult.isRefreshConfigCache()) {
- configService.refreshSystemConfigCache();
+ refreshSystemConfigCacheSafely("apply");
}
}
@@ -584,9 +584,17 @@
return List.of(rollbackChange);
}
- private void refreshRollbackConfigCacheIfNeeded(RollbackPersistenceResult persistenceResult) {
+ private void refreshRollbackConfigCacheSafely(RollbackPersistenceResult persistenceResult) {
if (persistenceResult != null && persistenceResult.isRefreshConfigCache()) {
+ refreshSystemConfigCacheSafely("rollback");
+ }
+ }
+
+ private void refreshSystemConfigCacheSafely(String scene) {
+ try {
configService.refreshSystemConfigCache();
+ } catch (RuntimeException exception) {
+ LOGGER.warn("AI鑷姩璋冨弬{}宸叉彁浜わ紝浣嗗埛鏂扮郴缁熼厤缃紦瀛樺け璐�", scene, exception);
}
}
--
Gitblit v1.9.1