diff --git a/db/db_impl.cc b/db/db_impl.cc index f381fd3ef..e529db3c7 100644 --- a/db/db_impl.cc +++ b/db/db_impl.cc @@ -955,6 +955,10 @@ Status DBImpl::RecoverLogFiles(const std::vector& log_numbers, } } + if (!status.ok()) { + return status; + } + flush_scheduler_.Clear(); if (versions_->LastSequence() < *max_sequence) { versions_->SetLastSequence(*max_sequence);