Skip to content

CASSANALYTICS-79: Make Token ranges calculation rack aware for spark.data.partitioner.CassandraRing #149

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom
Open
sklaha wants to merge 4 commits into
base: trunk
Choose a base branch
from
Open

CASSANALYTICS-79: Make Token ranges calculation rack aware for spark.data.partitioner.CassandraRing #149

sklaha wants to merge 4 commits into from

Conversation

@sklaha
Copy link
Contributor

@sklaha sklaha commented Oct 23, 2025

Changes in the PR:

  • An integration test (BulkReaderTokenRangeReplicasTest.java) has been added to demonstrate that the replicas for token range calculation were incorrect in CassandraRing with NetworkAwareReplication strategy in a multi-DC, multi-rack scenario.
  • The sidecar token-range-replicas API has been utilized to retrieve replicas for token ranges, eliminating the need for token range calculation within the analytics-library.
  • Unit tests have been added to further validate the changes.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Reviewers

No reviews

Assignees

No one assigned

Labels

None yet

Projects

None yet

Milestone

No milestone

Development

Successfully merging this pull request may close these issues.

1 participant

@sklaha