diff --git a/prometheus/src/main/java/com/alibaba/otter/canal/prometheus/impl/StoreCollector.java b/prometheus/src/main/java/com/alibaba/otter/canal/prometheus/impl/StoreCollector.java index e22eb251..81b90ba7 100644 --- a/prometheus/src/main/java/com/alibaba/otter/canal/prometheus/impl/StoreCollector.java +++ b/prometheus/src/main/java/com/alibaba/otter/canal/prometheus/impl/StoreCollector.java @@ -162,7 +162,7 @@ public class StoreCollector extends Collector implements InstanceRegistry { Preconditions.checkNotNull(holder.putMemSize); Preconditions.checkNotNull(holder.ackMemSize); } - StoreMetricsHolder old = instances.putIfAbsent(destination, holder); + StoreMetricsHolder old = instances.put(destination, holder); if (old != null) { logger.warn("Remote stale StoreCollector for instance {}.", destination); }