This is an automated email from the ASF dual-hosted git repository. tanxinyu pushed a commit to branch update_iot_consensus_throttle_message_12 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 693fa64c2cf09ad56ebd631bb468519d290d932d Author: OneSizeFitQuorum <[email protected]> AuthorDate: Thu Jun 8 16:38:53 2023 +0800 update messgae Signed-off-by: OneSizeFitQuorum <[email protected]> --- .../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();
