Github user bdeggleston commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/224#discussion_r194793488
--- Diff:
src/java/org/apache/cassandra/service/reads/AbstractReadExecutor.java ---
@@ -344,17 +351,18 @@ public void maybeTryAdditionalReplicas()
// no-op
}
- public List<InetAddressAndPort> getContactedReplicas()
+ public ReplicaList getContactedReplicas()
{
return targetReplicas;
}
@Override
public void executeAsync()
{
- makeDataRequests(targetReplicas.subList(0,
targetReplicas.size() > 1 ? 2 : 1));
+ Replicas.checkFull(targetReplicas);
+ makeDataRequests(targetReplicas.subList(0,
targetReplicas.size() > 1 ? 2 : 1).asEndpoints());
--- End diff --
fixed
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
