filter for empty memtables

fjall-rs · Dec 19, 2024 · e07497b · e07497b
1 parent 92e4a4c
commit e07497b
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/monitor.rs b/src/monitor.rs
@@ -58,6 +58,7 @@ impl Monitor {
         // TODO: this may not scale well for many partitions
         let lowest_persisted_partition = partitions
             .values()
+            .filter(|x| x.tree.active_memtable_size() > 0)
             .min_by(|a, b| {
                 a.tree
                     .get_highest_persisted_seqno()