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);