diff --git a/src/java/org/apache/cassandra/locator/MetaStrategy.java b/src/java/org/apache/cassandra/locator/MetaStrategy.java index ac9685227e..a16d4e68bb 100644 --- a/src/java/org/apache/cassandra/locator/MetaStrategy.java +++ b/src/java/org/apache/cassandra/locator/MetaStrategy.java @@ -60,7 +60,9 @@ public class MetaStrategy extends SystemStrategy @Override public ReplicationFactor getReplicationFactor() { - ClusterMetadata metadata = ClusterMetadata.current(); + ClusterMetadata metadata = ClusterMetadata.currentNullable(); + if (metadata == null || metadata.epoch.isEqualOrBefore(Epoch.FIRST)) + return ReplicationFactor.fullOnly(1); int rf = metadata.placements.get(ReplicationParams.meta(metadata)).writes.forRange(entireRange).get().byEndpoint.size(); return ReplicationFactor.fullOnly(rf); }