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 80983b3cbbab21d8f74a031e4c66138b0f0403b4 Author: Marcus Eriksson <[email protected]> AuthorDate: Wed Mar 22 13:22:12 2023 +0100 [CEP-21] Improve support for start/end tokens in nodetool rebuild patch by Marcus Eriksson; reviewed by Alex Petrov and Sam Tunnicliffe for CASSANDRA-18411 --- src/java/org/apache/cassandra/dht/RangeStreamer.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/java/org/apache/cassandra/dht/RangeStreamer.java b/src/java/org/apache/cassandra/dht/RangeStreamer.java index 6b75a8d7d6..e5347283ca 100644 --- a/src/java/org/apache/cassandra/dht/RangeStreamer.java +++ b/src/java/org/apache/cassandra/dht/RangeStreamer.java @@ -450,7 +450,7 @@ public class RangeStreamer EndpointsForRange wrappedEndpointsForRange = null; for (Range<Token> r : maybeWrappingRange.unwrap()) { - EndpointsForRange ep1 = placements.forRange(r); + EndpointsForRange ep1 = placements.forRange(r.right); if (wrappedEndpointsForRange == null) wrappedEndpointsForRange = ep1; assert wrappedEndpointsForRange.endpoints().equals(ep1.endpoints()) : wrappedEndpointsForRange +" != " + ep1; @@ -462,7 +462,7 @@ public class RangeStreamer } else { - endpoints = placements.forRange(maybeWrappingRange); + endpoints = placements.forRange(maybeWrappingRange.right); } return endpoints; } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
