This is an automated email from the ASF dual-hosted git repository.
yongzao pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new 369971c8164 fix datanode check (#15730)
369971c8164 is described below
commit 369971c8164e5bdd2fafc16eea9f6c55056e3860
Author: Xiangpeng Hu <[email protected]>
AuthorDate: Tue Jun 17 09:49:45 2025 +0800
fix datanode check (#15730)
---
.../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 d34e27a2321..a531d67955c 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()) {
