From 5127d2523fafe1dd9083a7d9ca0e14b54b0f793f Mon Sep 17 00:00:00 2001 From: daojun Date: Tue, 1 Nov 2022 15:46:04 +0800 Subject: [PATCH] fix metrics name --- .../pulsar/metadata/impl/stats/BatchMetadataStoreStats.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/stats/BatchMetadataStoreStats.java b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/stats/BatchMetadataStoreStats.java index ed3750777840e..f87155b9259be 100644 --- a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/stats/BatchMetadataStoreStats.java +++ b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/stats/BatchMetadataStoreStats.java @@ -97,6 +97,8 @@ public void close() throws Exception { if (closed.compareAndSet(false, true)) { EXECUTOR_QUEUE_SIZE.remove(this.metadataStoreName); OPS_WAITING.remove(this.metadataStoreName); + BATCH_EXECUTE_TIME.remove(this.metadataStoreName); + OPS_PER_BATCH.remove(metadataStoreName); } } }