[iotdb] branch update_iot_consensus_throttle_message updated: update messgae

[tanxinyu]

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

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


The following commit(s) were added to 
refs/heads/update_iot_consensus_throttle_message by this push:
     new 77e2cc7d579 update messgae
77e2cc7d579 is described below

commit 77e2cc7d57914c9edebe2995d790593e4ea77400
Author: OneSizeFitQuorum <tanxi...@apache.org>
AuthorDate: Thu Jun 8 16:38:53 2023 +0800

    update messgae
    
    Signed-off-by: OneSizeFitQuorum <tanxi...@apache.org>
---
 .../java/org/apache/iotdb/consensus/iot/IoTConsensusServerImpl.java  | 5 ++++-
 1 file changed, 4 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..97a725d9d63 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,9 @@ public class IoTConsensusServerImpl {
           if (timeout) {
             return RpcUtils.getStatus(
                 TSStatusCode.WRITE_PROCESS_REJECT,
-                "Reject write because there are too many requests need to 
process");
+                "The write is rejected because the wal directory size has 
reached the "
+                    + "threshold. You may need to adjust the flush policy of 
the storage engine or "
+                    + "the IoTConsensus synchronization parameter");
           }
         } catch (InterruptedException e) {
           logger.error("Failed to throttle down because ", e);
@@ -805,6 +807,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();