diff --git a/db/view/view.cc b/db/view/view.cc index 0f078b7676..0593a51fe8 100644 --- a/db/view/view.cc +++ b/db/view/view.cc @@ -1411,6 +1411,10 @@ future<> view_builder::stop() { // ignored }).handle_exception_type([] (const semaphore_timed_out&) { // ignored + }).finally([this] { + return parallel_for_each(_base_to_build_step, [] (std::pair& p) { + return p.second.reader.close(); + }); }); }); }