-
Notifications
You must be signed in to change notification settings - Fork 3.7k
Implement Shard and CoordinatorLog metadata durability #4360
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.
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
base: cep-45-mutation-tracking
Are you sure you want to change the base?
Conversation
src/java/org/apache/cassandra/replication/MutationTrackingService.java
Outdated
Show resolved
Hide resolved
localWitnessed = Offsets.Mutable.copy(witnessedOffsets.get(localNodeId)); | ||
|
||
witnessedOffsets.convertToPrimitiveMap(witnessed); | ||
persistedOffsets.convertToPrimitiveMap(persisted); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Would be good to make this incremental in the future, since every witnessed offset will eventually be persisted and reconciled
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I'm not sure about this one. We must overwrite the entire value of each list in the system table because of the representation, but that shouldn't be a big deal - the size of each list should be roughly the same - the head, with not gaps, collapsed into one range, plus the slightly sparse tail. I don't see how to make it incremental in this context, or what it'd bring. I could easily be missing something though.
patch by Aleksey Yeschenko; reviewed by Abe Ratnofsky for CASSANDRA-20882
patch by Aleksey Yeschenko; reviewed by Abe Ratnofsky for CASSANDRA-20882