diff --git a/clients/da-vinci-client/src/main/java/com/linkedin/davinci/stats/RocksDBMemoryStats.java b/clients/da-vinci-client/src/main/java/com/linkedin/davinci/stats/RocksDBMemoryStats.java index 89404f31ff..59eac52fd3 100644 --- a/clients/da-vinci-client/src/main/java/com/linkedin/davinci/stats/RocksDBMemoryStats.java +++ b/clients/da-vinci-client/src/main/java/com/linkedin/davinci/stats/RocksDBMemoryStats.java @@ -38,7 +38,6 @@ public class RocksDBMemoryStats extends AbstractVeniceStats { "rocksdb.cur-size-all-mem-tables", "rocksdb.size-all-mem-tables", "rocksdb.num-entries-active-mem-table", - "rocksdb.compaction.cancelled", "rocksdb.num-entries-imm-mem-tables", "rocksdb.num-deletes-active-mem-table", "rocksdb.num-deletes-imm-mem-tables", diff --git a/services/venice-server/src/main/java/com/linkedin/venice/stats/RocksDBStats.java b/services/venice-server/src/main/java/com/linkedin/venice/stats/RocksDBStats.java index 4d105797c1..223461329f 100644 --- a/services/venice-server/src/main/java/com/linkedin/venice/stats/RocksDBStats.java +++ b/services/venice-server/src/main/java/com/linkedin/venice/stats/RocksDBStats.java @@ -21,6 +21,7 @@ import static org.rocksdb.TickerType.BLOCK_CACHE_INDEX_MISS; import static org.rocksdb.TickerType.BLOCK_CACHE_MISS; import static org.rocksdb.TickerType.BLOOM_FILTER_USEFUL; +import static org.rocksdb.TickerType.COMPACTION_CANCELLED; import static org.rocksdb.TickerType.GET_HIT_L0; import static org.rocksdb.TickerType.GET_HIT_L1; import static org.rocksdb.TickerType.GET_HIT_L2_AND_UP; @@ -72,6 +73,7 @@ public class RocksDBStats extends AbstractVeniceStats { // we'll need to enable read_amp_bytes_per_bit in rocksDB config private final Sensor readAmplificationFactor; + private final Sensor compactionCancelled; public RocksDBStats(MetricsRepository metricsRepository, String name) { super(metricsRepository, name); @@ -107,6 +109,7 @@ public RocksDBStats(MetricsRepository metricsRepository, String name) { this.getHitL0 = registerSensor("rocksdb_get_hit_l0", GET_HIT_L0); this.getHitL1 = registerSensor("rocksdb_get_hit_l1", GET_HIT_L1); this.getHitL2AndUp = registerSensor("rocksdb_get_hit_l2_and_up", GET_HIT_L2_AND_UP); + this.compactionCancelled = registerSensor("rocksdb_compaction_cancelled", COMPACTION_CANCELLED); this.blockCacheHitRatio = registerSensor("rocksdb_block_cache_hit_ratio", new Gauge(() -> { if (rocksDBStat != null) {