diff --git a/database.cc b/database.cc index 17913bb66a..fc1afa3326 100644 --- a/database.cc +++ b/database.cc @@ -1073,7 +1073,7 @@ column_family::try_flush_memtable_to_sstable(lw_shared_ptr old, sstabl // If we failed this write we will try the write again and that will create a new flush reader // that will decrease dirty memory again. So we need to reset the accounting. old->revert_flushed_memory(); - return stop_iteration::no; + return stop_iteration(_async_gate.is_closed()); }); }); });