aratno commented on code in PR #4428:
URL: https://github.com/apache/cassandra/pull/4428#discussion_r2491172195
##########
src/java/org/apache/cassandra/replication/MutationTrackingService.java:
##########
@@ -915,6 +978,62 @@ static List<KeyspaceShards>
loadFromSystemTables(ClusterMetadata cluster, LongSu
}
}
+ private static class CoordinatedTransfers implements
Iterable<CoordinatedTransfer>
+ {
+ private final Collection<CoordinatedTransfer> transfers;
+
+ private CoordinatedTransfers(Collection<CoordinatedTransfer> transfers)
+ {
+ this.transfers = transfers;
+ }
+
+ private static CoordinatedTransfers create(KeyspaceShards shards,
Collection<SSTableReader> sstables, ConsistencyLevel cl)
+ {
+ // Clean up incoming SSTables to remove any existing
CoordinatorLogOffsets, can't be trusted
+ for (SSTableReader sstable : sstables)
+ {
+ try
+ {
+
sstable.mutateCoordinatorLogOffsetsAndReload(ImmutableCoordinatorLogOffsets.NONE);
Review Comment:
Let's loosen this up when we have consensus on the failure recovery
specification? Finishing up my draft of that specification now, will be ready
soon.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
