This is an automated email from the ASF dual-hosted git repository.
tanxinyu 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 8c8c8d58523 [IOTDB-5706] Data inconsistency between IoT protocol
replications (#11727)
8c8c8d58523 is described below
commit 8c8c8d58523c5597d14ed1f3111b8491a944198f
Author: Xiangpeng Hu <[email protected]>
AuthorDate: Fri Dec 15 15:11:08 2023 +0800
[IOTDB-5706] Data inconsistency between IoT protocol replications (#11727)
---
.../java/org/apache/iotdb/consensus/iot/client/DispatchLogHandler.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/client/DispatchLogHandler.java
b/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/client/DispatchLogHandler.java
index 88a8d90ebaa..b0c8e5f35c6 100644
---
a/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/client/DispatchLogHandler.java
+++
b/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/client/DispatchLogHandler.java
@@ -84,7 +84,8 @@ public class DispatchLogHandler implements
AsyncMethodCallback<TSyncLogEntriesRe
public static boolean needRetry(int statusCode) {
return statusCode == TSStatusCode.INTERNAL_SERVER_ERROR.getStatusCode()
|| statusCode == TSStatusCode.SYSTEM_READ_ONLY.getStatusCode()
- || statusCode == TSStatusCode.WRITE_PROCESS_REJECT.getStatusCode();
+ || statusCode == TSStatusCode.WRITE_PROCESS_REJECT.getStatusCode()
+ || statusCode == TSStatusCode.WRITE_PROCESS_ERROR.getStatusCode();
}
@Override