diff --git a/readers/mutation_readers.cc b/readers/mutation_readers.cc index 35ea870d7e..a6d11cd28a 100644 --- a/readers/mutation_readers.cc +++ b/readers/mutation_readers.cc @@ -1409,6 +1409,7 @@ private: if (_last_uncompacted_kind != mutation_fragment_v2::kind::partition_end) { _ignore_partition_end = true; _compactor.consume_end_of_partition(*this, _gc_consumer); + _last_uncompacted_kind = mutation_fragment_v2::kind::partition_end; _ignore_partition_end = false; } }