[iotdb] branch cluster_scalability updated: fix a bug of TSStatus.OK set redirect

[lta]

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

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


The following commit(s) were added to refs/heads/cluster_scalability by this 
push:
     new f8a1432  fix a bug of TSStatus.OK set redirect
f8a1432 is described below

commit f8a1432d2752fa19b48b6f51af243eec31e5f0bc
Author: lta <litiana...@163.com>
AuthorDate: Thu Jan 14 19:26:03 2021 +0800

    fix a bug of TSStatus.OK set redirect
---
 .../java/org/apache/iotdb/cluster/server/member/MetaGroupMember.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/cluster/src/main/java/org/apache/iotdb/cluster/server/member/MetaGroupMember.java
 
b/cluster/src/main/java/org/apache/iotdb/cluster/server/member/MetaGroupMember.java
index 5484bb5..9dc5d67 100644
--- 
a/cluster/src/main/java/org/apache/iotdb/cluster/server/member/MetaGroupMember.java
+++ 
b/cluster/src/main/java/org/apache/iotdb/cluster/server/member/MetaGroupMember.java
@@ -1298,7 +1298,7 @@ public class MetaGroupMember extends RaftMember {
     } else if (!ClusterConstant.EMPTY_NODE.equals(leader.get())) {
       TSStatus result = forwardPlan(plan, leader.get(), null);
       if (!StatusUtils.NO_LEADER.equals(result)) {
-        result.setRedirectNode(new EndPoint(leader.get().getIp(), 
leader.get().getClientPort()));
+        result = StatusUtils.getStatus(result, new 
EndPoint(leader.get().getIp(), leader.get().getClientPort()));
         return result;
       }
     }