From fb06216e3d4b6dcc51036ab2c694c02465df4298 Mon Sep 17 00:00:00 2001 From: Patrick Lee Date: Wed, 3 Jun 2026 14:50:06 -0500 Subject: [PATCH] CASSANDRA-21426:Fix AssertionError in hasReplicaWithOngoingRepair when parallel_repair_count > 1 --- .../org/apache/cassandra/repair/autorepair/AutoRepairUtils.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/java/org/apache/cassandra/repair/autorepair/AutoRepairUtils.java b/src/java/org/apache/cassandra/repair/autorepair/AutoRepairUtils.java index 82dd78caa195..cc13243a2d43 100644 --- a/src/java/org/apache/cassandra/repair/autorepair/AutoRepairUtils.java +++ b/src/java/org/apache/cassandra/repair/autorepair/AutoRepairUtils.java @@ -735,7 +735,7 @@ private static boolean hasReplicaWithOngoingRepair(AutoRepairHistory eligibleHis for (Map.Entry> entry : replicationStrategies.entrySet()) { AbstractReplicationStrategy replicationStrategy = entry.getKey(); - EndpointsByRange endpointsByRange = replicationStrategy.getRangeAddresses(StorageService.instance.getTokenMetadata()); + EndpointsByRange endpointsByRange = replicationStrategy.getRangeAddresses(StorageService.instance.getTokenMetadata().cachedOnlyTokenMap()); // get ranges of the eligible address for the given replication strategy. RangesAtEndpoint rangesAtEndpoint = StorageService.instance.getReplicas(replicationStrategy, eligibleBroadcastAddress);