[
https://issues.apache.org/jira/browse/CASSANDRA-21723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yahya Kisana reassigned CASSANDRA-21723:
----------------------------------------
Assignee: Yahya Kisana
> 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
> Assignee: Yahya Kisana
> Priority: Normal
>
> 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]
