diff --git a/db/write_thread.cc b/db/write_thread.cc index cd3a52391..66cec0e1b 100644 --- a/db/write_thread.cc +++ b/db/write_thread.cc @@ -317,7 +317,7 @@ void WriteThread::LaunchParallelFollowers(ParallelGroup* pg, while (w != pg->last_writer) { // Writers that won't write don't get sequence allotment - if (!w->CallbackFailed()) { + if (!w->CallbackFailed() && w->ShouldWriteToMemtable()) { sequence += WriteBatchInternal::Count(w->batch); } w = w->link_newer;