diff --git a/db/db_impl.cc b/db/db_impl.cc index 0f1d227cd3d1942c1941de12ba839bdaf59e8031..28cf48547af9a07c04a74796c416b5e1f35119d4 100644 --- a/db/db_impl.cc +++ b/db/db_impl.cc @@ -2945,6 +2945,7 @@ Status DBImpl::DoCompactionWork(CompactionState* compact, // Release mutex while we're actually doing the compaction work mutex_.Unlock(); + log_buffer->FlushBufferToLog(); const uint64_t start_micros = env_->NowMicros(); unique_ptr input(versions_->MakeInputIterator(compact->compaction));