[iotdb] branch master updated: change response code to WRITE_PROCESS_REJECT when limitation is triggered by wal size (#7143)

[qi...@apache.org]

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 23b05104df change response code to WRITE_PROCESS_REJECT when limitation is triggered by wal size (#7143)
23b05104df is described below

commit 23b05104dfd1b83d23fbaa0d3e4525d9f12c98a3
Author: Zhang.Jinrui <xi...@gmail.com>
AuthorDate: Fri Aug 26 23:11:31 2022 +0800

    change response code to WRITE_PROCESS_REJECT when limitation is triggered by wal size (#7143)
---
 .../org/apache/iotdb/consensus/multileader/MultiLeaderServerImpl.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/consensus/src/main/java/org/apache/iotdb/consensus/multileader/MultiLeaderServerImpl.java b/consensus/src/main/java/org/apache/iotdb/consensus/multileader/MultiLeaderServerImpl.java
index 619e9fb32d..0488daf658 100644
--- a/consensus/src/main/java/org/apache/iotdb/consensus/multileader/MultiLeaderServerImpl.java
+++ b/consensus/src/main/java/org/apache/iotdb/consensus/multileader/MultiLeaderServerImpl.java
@@ -127,7 +127,7 @@ public class MultiLeaderServerImpl {
               !stateMachineCondition.await(
                   config.getReplication().getThrottleTimeOutMs(), TimeUnit.MILLISECONDS);
           if (timeout) {
-            return RpcUtils.getStatus(TSStatusCode.READ_ONLY_SYSTEM_ERROR);
+            return RpcUtils.getStatus(TSStatusCode.WRITE_PROCESS_REJECT);
           }
         } catch (InterruptedException e) {
           logger.error("Failed to throttle down because ", e);