change req to right datanode when execute remove-datanode.sh (apache#…

…7319)
yonyou-tsdb · Sep 14, 2022 · c85d80e · c85d80e
1 parent 3a6efca
commit c85d80e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...ignode/src/main/java/org/apache/iotdb/confignode/procedure/env/DataNodeRemoveHandler.java b/...ignode/src/main/java/org/apache/iotdb/confignode/procedure/env/DataNodeRemoveHandler.java
@@ -170,7 +170,7 @@ public TSStatus addRegionPeer(TDataNodeLocation destDataNode, TConsensusGroupId
     }
 
     // Send addRegionPeer request to the selected DataNode
-    TMaintainPeerReq maintainPeerReq = new TMaintainPeerReq(regionId, selectedDataNode.get());
+    TMaintainPeerReq maintainPeerReq = new TMaintainPeerReq(regionId, destDataNode);
     status =
         SyncDataNodeClientPool.getInstance()
             .sendSyncRequestToDataNodeWithRetry(
@@ -213,7 +213,7 @@ public TSStatus removeRegionPeer(TDataNodeLocation originalDataNode, TConsensusG
     }
 
     // Send addRegionPeer request to the selected DataNode
-    TMaintainPeerReq maintainPeerReq = new TMaintainPeerReq(regionId, selectedDataNode.get());
+    TMaintainPeerReq maintainPeerReq = new TMaintainPeerReq(regionId, originalDataNode);
     status =
         SyncDataNodeClientPool.getInstance()
             .sendSyncRequestToDataNodeWithRetry(