diff --git a/fdbserver/TLogServer.actor.cpp b/fdbserver/TLogServer.actor.cpp index 2df743f1cf..7601218459 100644 --- a/fdbserver/TLogServer.actor.cpp +++ b/fdbserver/TLogServer.actor.cpp @@ -37,6 +37,7 @@ #include "ServerDBInfo.h" #include "LogSystem.h" #include "WaitFailure.h" +#include "fdbrpc/simulator.h" using std::pair; using std::make_pair; @@ -1411,6 +1412,10 @@ ACTOR Future restorePersistentState( TLogData* self, LocalityData locality state UID lastId = UID(1,1); //initialized so it will not compare equal to a default UID state double recoverMemoryLimit = SERVER_KNOBS->TARGET_BYTES_PER_TLOG + SERVER_KNOBS->SPRING_BYTES_TLOG; if (BUGGIFY) recoverMemoryLimit = std::max(SERVER_KNOBS->BUGGIFY_RECOVER_MEMORY_LIMIT, SERVER_KNOBS->TLOG_SPILL_THRESHOLD); + + //LowLatencyWithFailures needs to avoid flushing large queues + if (g_network->isSimulated() && g_simulator.connectionFailuresDisableDuration > 0) recoverMemoryLimit = 2000e6; + try { loop { if(allRemoved.isReady()) {