延长健康检查结果过期时间

zengqiao · ZQKC · commit 0e71ecc587e3 · 2022-10-29T13:55:07.000+08:00
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
@@ -60,7 +60,7 @@ private TaskResult calAndUpdateHealthCheckResult(ClusterPhy clusterPhy, long tri
 
         // 删除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);
         }

Original file line number	Diff line number	Diff line change
`@@ -60,7 +60,7 @@ private TaskResult calAndUpdateHealthCheckResult(ClusterPhy clusterPhy, long tri`
`60`	`60`
`61`	`61`	`// 删除10分钟之前的检查结果`
`62`	`62`	`try {`
`63`		`- healthCheckResultService.deleteByUpdateTimeBeforeInDB(clusterPhy.getId(), new Date(triggerTimeUnitMs - 10 * 60 * 1000));`
	`63`	`+ healthCheckResultService.deleteByUpdateTimeBeforeInDB(clusterPhy.getId(), new Date(triggerTimeUnitMs - 20 * 60 * 1000));`
`64`	`64`	`} catch (Exception e) {`
`65`	`65`	`log.error("class=AbstractHealthCheckTask\|\|method=processSubTask\|\|clusterPhyId={}\|\|errMsg=exception!", clusterPhy.getId(), e);`
`66`	`66`	`}`