(iotdb) branch dev/1.3 updated: fix datanode check (#15730) (#15737)

[yongzao]

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

yongzao pushed a commit to branch dev/1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/dev/1.3 by this push:
     new 0dd2f8c9d7f fix datanode check (#15730) (#15737)
0dd2f8c9d7f is described below

commit 0dd2f8c9d7fbcec18d97c0fffe579fb2978223fa
Author: Xiangpeng Hu <65238551+hxpser...@users.noreply.github.com>
AuthorDate: Tue Jun 17 14:32:01 2025 +0800

    fix datanode check (#15730) (#15737)
---
 .../confignode/procedure/impl/node/RemoveDataNodesProcedure.java     | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/node/RemoveDataNodesProcedure.java
 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/node/RemoveDataNodesProcedure.java
index 1340d968a7e..68b0550e0df 100644
--- 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/node/RemoveDataNodesProcedure.java
+++ 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/node/RemoveDataNodesProcedure.java
@@ -214,7 +214,10 @@ public class RemoveDataNodesProcedure extends 
AbstractNodeProcedure<RemoveDataNo
     for (TDataNodeLocation dataNode : removedDataNodes) {
       List<TConsensusGroupId> migratedFailedRegions =
           replicaSets.stream()
-              .filter(replica -> 
replica.getDataNodeLocations().contains(dataNode))
+              .filter(
+                  replica ->
+                      replica.getDataNodeLocations().stream()
+                          .anyMatch(loc -> loc.getDataNodeId() == 
dataNode.dataNodeId))
               .map(TRegionReplicaSet::getRegionId)
               .collect(Collectors.toList());
       if (!migratedFailedRegions.isEmpty()) {