Saranya Krishnakumar created CASSANDRA-21723:
------------------------------------------------

             Summary: Wrap-around shard silently skipped during coordinated 
SSTable import for mutation tracking enabled tables
                 Key: CASSANDRA-21723
                 URL: https://issues.apache.org/jira/browse/CASSANDRA-21723
             Project: Apache Cassandra
          Issue Type: Bug
            Reporter: Saranya Krishnakumar


TrackedImportTransfers.create() creates shards for streaming during SSTable 
import for tracked tables. For the wrap around shard, with min>max, 
IntervalTree.search silently returns an empty list of SSTables. As a result, no 
TrackedImportTransfer is created for that shard, and a SELECT query after 
successful import returns partial data. Fix needed is to create the interval 
with Interval tree's actual maximum bound when right < left endpoint, so that 
the wrap-around shard's data is transferred.

For a 3 node cluster with tokens, -5534023222112865485, -1844674407370955163 
and 1844674407370955159
Shards from system.shards are:
-9223372036854775808,-5534023222112865485
-5534023222112865485,-1844674407370955163
-1844674407370955163,1844674407370955159
1844674407370955159, -9223372036854775808

>From import logs for node 1, only 3 shards are transferred,
INFO  [node1_LocalTrackedTransfers:2] 2026-09-24 15:30:09,543 
TrackedImportTransfer.java:375 - [TrackedImportTransfer #MutationId\{1, 1, 18, 
1790289009}] Starting streaming transfer 
TrackedImportTransfer{keyspace='sstable_import_tracked', 
range=(-9223372036854775808,-5534023222112865485]
INFO  [node1_LocalTrackedTransfers:2] 2026-09-24 15:30:09,704 
TrackedImportTransfer.java:375 - [TrackedImportTransfer #MutationId\{1, 3, 26, 
1790289009}] Starting streaming transfer 
TrackedImportTransfer{keyspace='sstable_import_tracked', 
range=(-5534023222112865485,-1844674407370955163]
INFO  [node1_LocalTrackedTransfers:2] 2026-09-24 15:30:09,814 
TrackedImportTransfer.java:375 - [TrackedImportTransfer #MutationId\{1, 4, 16, 
1790289009}] Starting streaming transfer 
TrackedImportTransfer{keyspace='sstable_import_tracked', 
range=(-1844674407370955163,1844674407370955159]



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to