From 0e71ecc587e325ef61dd29a6afa6568b899b84a2 Mon Sep 17 00:00:00 2001 From: zengqiao Date: Sat, 29 Oct 2022 13:29:48 +0800 Subject: [PATCH] =?UTF-8?q?=E5=BB=B6=E9=95=BF=E5=81=A5=E5=BA=B7=E6=A3=80?= =?UTF-8?q?=E6=9F=A5=E7=BB=93=E6=9E=9C=E8=BF=87=E6=9C=9F=E6=97=B6=E9=97=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../know/streaming/km/task/health/AbstractHealthCheckTask.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/health/AbstractHealthCheckTask.java b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/health/AbstractHealthCheckTask.java index 4d614881..711a4ef6 100644 --- a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/health/AbstractHealthCheckTask.java +++ b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/health/AbstractHealthCheckTask.java @@ -60,7 +60,7 @@ public abstract class AbstractHealthCheckTask extends AbstractAsyncMetricsDispat // 删除10分钟之前的检查结果 try { - healthCheckResultService.deleteByUpdateTimeBeforeInDB(clusterPhy.getId(), new Date(triggerTimeUnitMs - 10 * 60 * 1000)); + healthCheckResultService.deleteByUpdateTimeBeforeInDB(clusterPhy.getId(), new Date(triggerTimeUnitMs - 20 * 60 * 1000)); } catch (Exception e) { log.error("class=AbstractHealthCheckTask||method=processSubTask||clusterPhyId={}||errMsg=exception!", clusterPhy.getId(), e); }