diff options
| author | tanghao <[email protected]> | 2024-08-22 17:10:47 +0800 |
|---|---|---|
| committer | tanghao <[email protected]> | 2024-08-22 17:10:47 +0800 |
| commit | dc87f4b5f4230d8a11c0883f707821116ef965fc (patch) | |
| tree | 95d88b4937499404d9bd92e935338f81e19d1382 | |
| parent | 5490ecffa377979f2792e9be3185822c535e0496 (diff) | |
fix: Detection处理过期数据存入数据库改为等待实现
| -rw-r--r-- | cn-admin/src/main/java/net/geedge/modules/detection/job/DetectionEventExpiredJob.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/cn-admin/src/main/java/net/geedge/modules/detection/job/DetectionEventExpiredJob.java b/cn-admin/src/main/java/net/geedge/modules/detection/job/DetectionEventExpiredJob.java index ed89350..dfb034f 100644 --- a/cn-admin/src/main/java/net/geedge/modules/detection/job/DetectionEventExpiredJob.java +++ b/cn-admin/src/main/java/net/geedge/modules/detection/job/DetectionEventExpiredJob.java @@ -77,7 +77,7 @@ public class DetectionEventExpiredJob extends QuartzJobBean { clickHouseClient.write(clickHouseNode) .format(ClickHouseFormat.RowBinaryWithNamesAndTypes) .query(batchInsertSql) - .execute(); + .executeAndWait(); //存入数据库后 移除缓存中数据 for (String key : removeKeys) { cache.remove(key); |