diff --git a/sstables/sstables.cc b/sstables/sstables.cc index 545efb6943..6d268e149f 100644 --- a/sstables/sstables.cc +++ b/sstables/sstables.cc @@ -1308,6 +1308,7 @@ void sstable::prepare_write_components(::mutation_reader mr, uint64_t estimated_ } future<> sstable::write_components(const memtable& mt) { + _collector.set_replay_position(mt.replay_position()); return write_components(mt.make_reader(), mt.partition_count(), mt.schema()); }