diff --git a/db/view/view.cc b/db/view/view.cc index 066f9691fb..9a4308988d 100644 --- a/db/view/view.cc +++ b/db/view/view.cc @@ -1494,7 +1494,7 @@ future<> view_builder::initialize_reader_at_current_token(build_step& step) { return step.reader.close().then([this, &step] { step.pslice = make_partition_slice(*step.base->schema()); step.prange = dht::partition_range(dht::ring_position::starting_at(step.current_token()), dht::ring_position::max()); - step.reader = downgrade_to_v1(step.base->get_sstable_set().make_local_shard_sstable_reader( + step.reader = step.base->get_sstable_set().make_local_shard_sstable_reader( step.base->schema(), _permit, step.prange, @@ -1502,7 +1502,7 @@ future<> view_builder::initialize_reader_at_current_token(build_step& step) { default_priority_class(), nullptr, streamed_mutation::forwarding::no, - mutation_reader::forwarding::no)); + mutation_reader::forwarding::no); }); } diff --git a/db/view/view_builder.hh b/db/view/view_builder.hh index 7cdf6b0616..d7a695c119 100644 --- a/db/view/view_builder.hh +++ b/db/view/view_builder.hh @@ -135,7 +135,7 @@ class view_builder final : public service::migration_listener::only_view_notific lw_shared_ptr base; query::partition_slice pslice; dht::partition_range prange; - flat_mutation_reader reader{nullptr}; + flat_mutation_reader_v2 reader{nullptr}; dht::decorated_key current_key{dht::minimum_token(), partition_key::make_empty()}; std::vector build_status;