diff --git a/db/compaction/compaction_picker_fifo.cc b/db/compaction/compaction_picker_fifo.cc index 4ff301d21c37cc4db2b6d2f8c74d84cf3dcd4a37..cacb33c22735617763eb4b7e703807af2a95292f 100644 --- a/db/compaction/compaction_picker_fifo.cc +++ b/db/compaction/compaction_picker_fifo.cc @@ -54,6 +54,15 @@ Compaction* FIFOCompactionPicker::PickTTLCompaction( } const uint64_t current_time = static_cast(_current_time); + if (!level0_compactions_in_progress_.empty()) { + ROCKS_LOG_BUFFER( + log_buffer, + "[%s] FIFO compaction: Already executing compaction. No need " + "to run parallel compactions since compactions are very fast", + cf_name.c_str()); + return nullptr; + } + std::vector inputs; inputs.emplace_back(); inputs[0].level = 0;