diff --git a/db/db_impl.cc b/db/db_impl.cc index 49b9595..d405e58 100644 --- a/db/db_impl.cc +++ b/db/db_impl.cc @@ -1275,6 +1275,8 @@ WriteBatch* DBImpl::BuildBatchGroup(Writer** last_writer) { WriteBatchInternal::Append(result, first->batch); } WriteBatchInternal::Append(result, w->batch); + } else { + break; } *last_writer = w; }