diff --git a/db/view/view.cc b/db/view/view.cc index 613a44b101..0f078b7676 100644 --- a/db/view/view.cc +++ b/db/view/view.cc @@ -854,6 +854,10 @@ public: future> build(); + future<> close() noexcept { + return when_all_succeed(_updates.close(), _existings->close()).discard_result(); + } + private: void generate_update(clustering_row&& update, std::optional&& existing); future on_results(); @@ -1039,7 +1043,9 @@ future> generate_view_updates( })); auto builder = std::make_unique(base, std::move(vs), std::move(updates), std::move(existings), now); auto f = builder->build(); - return f.finally([builder = std::move(builder)] { }); + return f.finally([builder = std::move(builder)] { + return builder->close(); + }); } query::clustering_row_ranges calculate_affected_clustering_ranges(const schema& base,