[iotdb] branch master updated: Update the iotconsensus write-blocking prompt to make error messages more friendly (#10082)

[qiaojialin]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 14ae00eca74 Update the iotconsensus write-blocking prompt to make 
error messages more friendly (#10082)
14ae00eca74 is described below

commit 14ae00eca749d8d4f651da9934c5955eda2add4d
Author: Potato <tanxi...@apache.org>
AuthorDate: Thu Jun 8 20:19:39 2023 +0800

    Update the iotconsensus write-blocking prompt to make error messages more 
friendly (#10082)
---
 .../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();