diff --git a/src/Service/RequestProcessor.cpp b/src/Service/RequestProcessor.cpp index 1dc86a9d30..656d297a22 100644 --- a/src/Service/RequestProcessor.cpp +++ b/src/Service/RequestProcessor.cpp @@ -137,8 +137,8 @@ bool RequestProcessor::shouldProcessCommittedRequest(const RequestForSession & c found_in_pending_queue = false; LOG_WARNING( this->log, - "Not found committed(write) request {} in pending queue. Possible reason: 1.close requests from deadSessionCleanThread are not put " - "into pending queue; 2.error occurs(because of forward or append entries) but request is still committed, " + "Not found committed(write) request {} in pending queue. Possible reason: 1.close requests from deadSessionCleanThread are not " + "put into pending queue; 2.error occurs(because of forward or append entries) but request is still committed, " "'processErrorRequest' may delete request from pending request first, so here we can not find it.", committed_request.toSimpleString()); }; @@ -349,10 +349,10 @@ void RequestProcessor::processErrorRequest(size_t count) { LOG_WARNING( this->log, - "Not found error request {} in pending queue. Possible reason: 1.close requests from deadSessionCleanThread are not put " - "into pending queue; 2.error occurs(forward or append entries) but request is still committed, " - "'processCommittedRequest' may delete request from pending request first, so here we can not find it. We also delete " - "it from errors.", + "Not found error request {} in pending queue. Possible reason: 1. request forwarding error; 2.close requests from " + "deadSessionCleanThread are not put into pending queue; 3.error occurs(forward or append entries) but request is still " + "committed, 'processCommittedRequest' may delete request from pending request first, so here we can not find it. We " + "also delete it from errors.", error_request.toString()); error_request_ids.erase(error_request.getRequestId());