[iotdb] branch native_raft updated: ensure redirection

[jiangtian]

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

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


The following commit(s) were added to refs/heads/native_raft by this push:
     new c7c2d47f2e ensure redirection
c7c2d47f2e is described below

commit c7c2d47f2e865c592822f859488e15e564f9b22e
Author: Tian Jiang <jt2594...@163.com>
AuthorDate: Thu May 11 09:41:18 2023 +0800

    ensure redirection
---
 .../java/org/apache/iotdb/consensus/natraft/protocol/RaftMember.java  | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/consensus/src/main/java/org/apache/iotdb/consensus/natraft/protocol/RaftMember.java
 
b/consensus/src/main/java/org/apache/iotdb/consensus/natraft/protocol/RaftMember.java
index f7f58b5721..07d02ceb43 100644
--- 
a/consensus/src/main/java/org/apache/iotdb/consensus/natraft/protocol/RaftMember.java
+++ 
b/consensus/src/main/java/org/apache/iotdb/consensus/natraft/protocol/RaftMember.java
@@ -795,7 +795,9 @@ public class RaftMember {
   }
 
   public ConsensusWriteResponse executeForwardedRequest(IConsensusRequest 
request) {
-    return new ConsensusWriteResponse(null, processRequest(request));
+    TSStatus tsStatus = processRequest(request);
+    tsStatus.setRedirectNode(thisNode.getEndpoint());
+    return new ConsensusWriteResponse(null, tsStatus);
   }
 
   /**