diff --git a/mutation_compactor.hh b/mutation_compactor.hh index fd7a662226..d284e649b4 100644 --- a/mutation_compactor.hh +++ b/mutation_compactor.hh @@ -291,6 +291,10 @@ public: // We are passing only dead (purged) data so pass is_live=false. gc_consumer.consume(std::move(sr_garbage), current_tombstone, false); }); + } else { + if (can_purge_tombstone(current_tombstone)) { + current_tombstone = {}; + } } _static_row_live = is_live; if (is_live || (!only_live() && !sr.empty())) { @@ -333,6 +337,10 @@ public: // We are passing only dead (purged) data so pass is_live=false. gc_consumer.consume(std::move(cr_garbage), t, false); }); + } else { + if (can_purge_tombstone(t)) { + t = {}; + } } if (only_live() && is_live) {