natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Include system_cluster_metadata keyspace in a full rebuild of all keyspaces

This commit is contained in:
Sam Tunnicliffe 2026-07-03 17:08:51 +01:00
parent e053c5f6d7
commit 46c85980fc
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/java/org/apache/cassandra/service/Rebuild.java
View File

@ -58,6 +58,7 @@ import org.apache.cassandra.utils.concurrent.Future;
import org.apache.cassandra.utils.concurrent.FutureCombiner; import org.apache.cassandra.utils.concurrent.FutureCombiner;
import org.apache.cassandra.utils.concurrent.UncheckedInterruptedException; import org.apache.cassandra.utils.concurrent.UncheckedInterruptedException;
import static org.apache.cassandra.schema.SchemaConstants.METADATA_KEYSPACE_NAME;
import static org.apache.cassandra.utils.FBUtilities.getBroadcastAddressAndPort; import static org.apache.cassandra.utils.FBUtilities.getBroadcastAddressAndPort;
public class Rebuild public class Rebuild
@ -236,6 +237,9 @@ public class Rebuild
if (keyspace == null) if (keyspace == null)
{ {
placements.forEach((params, placement) -> movementMapBuilder.put(params, addMovementsForParams(placement, null))); placements.forEach((params, placement) -> movementMapBuilder.put(params, addMovementsForParams(placement, null)));
// Special case to include the system metadata keyspace
ReplicationParams metaParams = Keyspace.open(METADATA_KEYSPACE_NAME).getMetadata().params.replication;
movementMapBuilder.put(metaParams, addMovementsForParams(metadata.placement(metaParams), null));
} }
else if (tokens == null) else if (tokens == null)
{ {