wyl/hertzbeat
1
0
Fork 0
mirror of https://github.com/dromara/hertzbeat.git synced 2026-09-17 09:40:58 +00:00
Code Issues Projects Releases Wiki Activity

[bugfix](warehouse) add metrics data update logic in memory storage (#2973)

Browse Source 
Co-authored-by: tomsun28 <tomsun28@outlook.com>
This commit is contained in:
Logic
2025-01-10 20:10:01 +08:00
committed by GitHub
co-authored by tomsun28
parent e905f36de2
commit db23c94882
1 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
hertzbeat-warehouse/src/main/java/org/apache/hertzbeat/warehouse/store/realtime/memory/MemoryDataStorage.java
+7 -1
View File
@@ -72,7 +72,13 @@ public class MemoryDataStorage extends AbstractRealTimeDataStorage {
if (metricsData.getCode() != CollectRep.Code.SUCCESS) {
return;
}
Map<String, CollectRep.MetricsData> metricsDataMap = monitorMetricsDataMap.computeIfAbsent(monitorId, key -> new ConcurrentHashMap<>(METRICS_SIZE));
Map<String, CollectRep.MetricsData> metricsDataMap =
monitorMetricsDataMap.computeIfAbsent(monitorId, key -> new ConcurrentHashMap<>(METRICS_SIZE));
CollectRep.MetricsData oldMetricsData = metricsDataMap.get(metrics);
if (oldMetricsData != null) {
oldMetricsData.close();
}
metricsDataMap.put(metrics, metricsData);
}