This is an automated email from the ASF dual-hosted git repository. samt pushed a commit to branch cep-21-tcm in repository https://gitbox.apache.org/repos/asf/cassandra.git
commit 00d78e56ba218fb579c9f36f9821a54fae8f802a Author: Sam Tunnicliffe <[email protected]> AuthorDate: Thu Mar 23 16:24:38 2023 +0000 [CEP-21] Remove paranoid check during SRPP patch by Sam Tunnicliffe; reviewed by Alex Petrov and Marcus Eriksson for CASSANDRA-18407 --- src/java/org/apache/cassandra/locator/ReplicaPlans.java | 5 ----- 1 file changed, 5 deletions(-) diff --git a/src/java/org/apache/cassandra/locator/ReplicaPlans.java b/src/java/org/apache/cassandra/locator/ReplicaPlans.java index 6d3ffd589f..baf4e73a78 100644 --- a/src/java/org/apache/cassandra/locator/ReplicaPlans.java +++ b/src/java/org/apache/cassandra/locator/ReplicaPlans.java @@ -713,11 +713,6 @@ public class ReplicaPlans private static ReplicaPlan.ForRangeRead forSingleReplicaRead(ClusterMetadata metadata, Keyspace keyspace, AbstractBounds<PartitionPosition> range, Replica replica, int vnodeCount) { - ReplicaLayout.ForRangeRead forRangeRead = ReplicaLayout.forRangeReadLiveSorted(metadata, keyspace, keyspace.getReplicationStrategy(), range); - - if (!forRangeRead.all().contains(replica)) - throw UnavailableException.create(ConsistencyLevel.ONE, 1, 1, forRangeRead.all().size(), forRangeRead.all().size()); - // TODO: this is unsafe, as one.range() may be inconsistent with our supplied range; should refactor Range/AbstractBounds to single class EndpointsForRange one = EndpointsForRange.of(replica); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
