From 64fb6e4ddaeff2ff4f73e202614276fbfd09eda5 Mon Sep 17 00:00:00 2001
From: lipanpan03 <656461146@qq.com>
Date: Fri, 15 Dec 2023 14:10:21 +0800
Subject: [PATCH] add witness

---
 .../src/main/java/com/antgroup/tugraph/TuGraphDbRpcClient.java  | 2 ++
 .../src/main/java/com/antgroup/tugraph/model/RaftState.java     | 2 ++
 2 files changed, 4 insertions(+)

diff --git a/rpc-client/src/main/java/com/antgroup/tugraph/TuGraphDbRpcClient.java b/rpc-client/src/main/java/com/antgroup/tugraph/TuGraphDbRpcClient.java
index 295165b..46741e9 100644
--- a/rpc-client/src/main/java/com/antgroup/tugraph/TuGraphDbRpcClient.java
+++ b/rpc-client/src/main/java/com/antgroup/tugraph/TuGraphDbRpcClient.java
@@ -338,6 +338,8 @@ private void refreshClientPool() {
             ClusterInfo clusterInfo = JSON.parseObject(JSON.parseArray(result).get(0).toString(), new TypeReference<ClusterInfo>(){});
             List<RaftState> raftStates = clusterInfo.getClusterInfo();
             raftStates.forEach(x -> {
+                if (x.getState().equals(RaftState.StateConstant.WITNESS))
+                    return;
                 TuGraphSingleRpcClient rpcClient = new TuGraphSingleRpcClient("list://" + x.getRpcAddress(), user, password);
                 rpcClientPool.add(rpcClient);
                 if (x.getState().equals(RaftState.StateConstant.MASTER)) {
diff --git a/rpc-client/src/main/java/com/antgroup/tugraph/model/RaftState.java b/rpc-client/src/main/java/com/antgroup/tugraph/model/RaftState.java
index 99dd2f6..d3640a0 100644
--- a/rpc-client/src/main/java/com/antgroup/tugraph/model/RaftState.java
+++ b/rpc-client/src/main/java/com/antgroup/tugraph/model/RaftState.java
@@ -28,6 +28,8 @@ public static class StateConstant {
         public final static String MASTER = "MASTER";
 
         public final static String FOLLOW = "FOLLOW";
+
+        public final static String WITNESS = "WITNESS";
     }
 
 }