diff --git a/src/kvstore/raftex/RaftPart.cpp b/src/kvstore/raftex/RaftPart.cpp
index ca34208e984..e6e14457c7f 100644
--- a/src/kvstore/raftex/RaftPart.cpp
+++ b/src/kvstore/raftex/RaftPart.cpp
@@ -830,6 +830,7 @@ folly::Future<nebula::cpp2::ErrorCode> RaftPart::appendLogAsync(ClusterID source
   {
     std::lock_guard<std::mutex> lck(logsLock_);
     AppendLogsIteratorFactory::make(logs_, sendingLogs_);
+    bufferOverFlow_ = false;
     if (sendingLogs_.empty()) {
       replicatingLogs_ = false;
       return retFuture;