diff --git a/src/java/org/apache/cassandra/tcm/ClusterMetadata.java b/src/java/org/apache/cassandra/tcm/ClusterMetadata.java index 34849584da..b4b8e5024d 100644 --- a/src/java/org/apache/cassandra/tcm/ClusterMetadata.java +++ b/src/java/org/apache/cassandra/tcm/ClusterMetadata.java @@ -237,9 +237,7 @@ public class ClusterMetadata return fullCMSMembers().contains(endpoint); // special case to handle initialization of the CMS for the first time - return epoch.isEqualOrBefore(Epoch.FIRST) && cmsDataPlacement.reads.byEndpoint() - .keySet() - .contains(endpoint); + return cmsDataPlacement.reads.byEndpoint().keySet().contains(endpoint); } public Set fullCMSMembers()