diff --git a/mutation_compactor.hh b/mutation_compactor.hh index 52ee7bb011..841d55656c 100644 --- a/mutation_compactor.hh +++ b/mutation_compactor.hh @@ -177,7 +177,6 @@ private: template requires CompactedFragmentsConsumerV2 && CompactedFragmentsConsumerV2 stop_iteration do_consume(range_tombstone_change&& rtc, Consumer& consumer, GCConsumer& gc_consumer) { - _validator(mutation_fragment_v2::kind::range_tombstone_change, rtc.position(), rtc.tombstone()); stop_iteration gc_consumer_stop = stop_iteration::no; stop_iteration consumer_stop = stop_iteration::no; if (rtc.tombstone() <= _partition_tombstone) { @@ -199,6 +198,7 @@ private: partition_is_not_empty(consumer); _current_emitted_tombstone = rtc.tombstone(); consumer_stop = consumer.consume(std::move(rtc)); + _validator(mutation_fragment_v2::kind::range_tombstone_change, rtc.position(), rtc.tombstone()); } return gc_consumer_stop || consumer_stop; }