[iotdb] branch rel/1.2 updated: [To rel/1.2] Update the iotconsensus write-blocking prompt to make error messages more friendly (#10083)

[qiaojialin]

This is an automated email from the ASF dual-hosted git repository.

qiaojialin pushed a commit to branch rel/1.2
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/rel/1.2 by this push:
     new 2e6b083e08d [To rel/1.2] Update the iotconsensus write-blocking prompt 
to make error messages more friendly (#10083)
2e6b083e08d is described below

commit 2e6b083e08dfd7f913d8d01cd505749c87c24f44
Author: Potato <tanxi...@apache.org>
AuthorDate: Thu Jun 8 20:20:35 2023 +0800

    [To rel/1.2] Update the iotconsensus write-blocking prompt to make error 
messages more friendly (#10083)
---
 .../org/apache/iotdb/consensus/iot/IoTConsensusServerImpl.java     | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git 
a/consensus/src/main/java/org/apache/iotdb/consensus/iot/IoTConsensusServerImpl.java
 
b/consensus/src/main/java/org/apache/iotdb/consensus/iot/IoTConsensusServerImpl.java
index 62c498f4b18..7a0869b7ace 100644
--- 
a/consensus/src/main/java/org/apache/iotdb/consensus/iot/IoTConsensusServerImpl.java
+++ 
b/consensus/src/main/java/org/apache/iotdb/consensus/iot/IoTConsensusServerImpl.java
@@ -186,7 +186,11 @@ public class IoTConsensusServerImpl {
           if (timeout) {
             return RpcUtils.getStatus(
                 TSStatusCode.WRITE_PROCESS_REJECT,
-                "Reject write because there are too many requests need to 
process");
+                String.format(
+                    "The write is rejected because the wal directory size has 
reached the "
+                        + "threshold %d bytes. You may need to adjust the 
flush policy of the "
+                        + "storage engine or the IoTConsensus synchronization 
parameter",
+                    config.getReplication().getWalThrottleThreshold()));
           }
         } catch (InterruptedException e) {
           logger.error("Failed to throttle down because ", e);
@@ -805,6 +809,7 @@ public class IoTConsensusServerImpl {
    * deserialization of PlanNode to be concurrent
    */
   private class SyncLogCacheQueue {
+
     private final int sourcePeerId;
     private final Lock queueLock = new ReentrantLock();
     private final Condition queueSortCondition = queueLock.newCondition();