[enh][broker] Allow to leverage pending reads with partial coverage (#…

…120) - fix metrics
lhotari · Aug 26, 2022 · 3d1d175 · 3d1d175
1 parent 0427838
commit 3d1d175
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/...ed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/cache/RangeEntryCacheImpl.java b/...ed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/cache/RangeEntryCacheImpl.java
@@ -61,22 +61,22 @@ public class RangeEntryCacheImpl implements EntryCache {
             .build()
             .name("pulsar_ml_cache_pendingreads_matched")
             .help("Pending reads reused with perfect range match")
-            .create();
+            .register();
     private static final Counter COUNT_PENDING_READS_MATCHED_INCLUDED = Counter
             .build()
             .name("pulsar_ml_cache_pendingreads_matched_included")
             .help("Pending reads reused by attaching to a read with a larger range")
-            .create();
+            .register();
     private static final Counter COUNT_PENDING_READS_MISSED = Counter
             .build()
             .name("pulsar_ml_cache_pendingreads_missed")
             .help("Pending reads that didn't find a match")
-            .create();
+            .register();
     private static final Counter COUNT_PENDING_READS_MISSED_BUT_OVERLAPPING = Counter
             .build()
             .name("pulsar_ml_cache_pendingreads_missed_overlapping")
             .help("Pending reads that didn't find a match but they partially overlap with another read")
-            .create();
+            .register();
 
     static final Summary PULSAR_ML_CACHE_ENTRY_RANGE_SIZE = Summary.build()
             .name("pulsar_ml_cache_entry_range_size")