[collector]bugfix: close connection when common cache is timeout (apa…

…che#2786) Co-authored-by: shown <[email protected]> Co-authored-by: aias00 <[email protected]>
Aias00 · Oct 29, 2024 · afe68ba · afe68ba
1 parent 4da00d4
commit afe68ba
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/.../main/java/org/apache/hertzbeat/collector/collect/common/cache/ConnectionCommonCache.java b/.../main/java/org/apache/hertzbeat/collector/collect/common/cache/ConnectionCommonCache.java
@@ -147,8 +147,7 @@ public Optional<C> getCache(T key, boolean refreshCache) {
         }
         if (cacheTime[0] + cacheTime[1] < System.currentTimeMillis()) {
             log.warn("[connection common cache] is timeout, remove it, key {}.", key);
-            timeoutMap.remove(key);
-            cacheMap.remove(key);
+            removeCache(key);
             return Optional.empty();
         }
         C value = cacheMap.compute(key, (k, v) -> {