Skip to content

Commit db6eec9

Browse files
committed
fix datanode check
1 parent ac89802 commit db6eec9

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/node/RemoveDataNodesProcedure.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -214,7 +214,10 @@ private void checkRegionStatusAndStopDataNode(ConfigNodeProcedureEnv env) {
214214
for (TDataNodeLocation dataNode : removedDataNodes) {
215215
List<TConsensusGroupId> migratedFailedRegions =
216216
replicaSets.stream()
217-
.filter(replica -> replica.getDataNodeLocations().contains(dataNode))
217+
.filter(
218+
replica ->
219+
replica.getDataNodeLocations().stream()
220+
.anyMatch(loc -> loc.getDataNodeId() == dataNode.dataNodeId))
218221
.map(TRegionReplicaSet::getRegionId)
219222
.collect(Collectors.toList());
220223
if (!migratedFailedRegions.isEmpty()) {

0 commit comments

Comments
 (0)