Github user ifesdjeen commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/224#discussion_r197135878
--- Diff: src/java/org/apache/cassandra/service/StorageService.java ---
@@ -3788,7 +3789,10 @@ public void forceTerminateAllRepairSessions()
if (metadata == null)
throw new IllegalArgumentException("Unknown table '" + cf + "'
in keyspace '" + keyspaceName + "'");
- return getNaturalEndpoints(keyspaceName,
tokenMetadata.partitioner.getToken(metadata.partitionKeyType.fromString(key))).stream().map(i
-> i.address).collect(toList());
+ ReplicaList replicas = getNaturalReplicas(keyspaceName,
tokenMetadata.partitioner.getToken(metadata.partitionKeyType.fromString(key)));
--- End diff --
We could use `replicas.asEndpointsList`, and return list of
`InetAddressAndPort.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
