Skip to content

Commit 0dd2f8c

Browse files
authored
fix datanode check (#15730) (#15737)
1 parent b33fc38 commit 0dd2f8c

1 file changed

Lines changed: 4 additions & 1 deletion

File tree

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)