diff --git a/src/java/org/apache/cassandra/service/StorageService.java b/src/java/org/apache/cassandra/service/StorageService.java index 2ad2a5bf27..53f0986e0c 100644 --- a/src/java/org/apache/cassandra/service/StorageService.java +++ b/src/java/org/apache/cassandra/service/StorageService.java @@ -1761,19 +1761,6 @@ public class StorageService extends NotificationBroadcasterSupport implements IE return pojoMapToString(snapshotAsMap, format); } - @Override - public String getCmsCommitMemberPreferencePolicy() - { - return DatabaseDescriptor.getCmsCommitMemberPreferencePolicy().name(); - } - - @Override - public void setCmsCommitMemberPreferencePolicy(String policy) - { - DatabaseDescriptor.setCmsCommitMemberPreferencePolicy(policy); - logger.info("Set cms_commit_member_preference_policy to {}", policy); - } - public Map> getConcurrency(List stageNames) { Stream stageStream = stageNames.isEmpty() ? stream(Stage.values()) : stageNames.stream().map(Stage::fromPoolName); diff --git a/src/java/org/apache/cassandra/service/StorageServiceMBean.java b/src/java/org/apache/cassandra/service/StorageServiceMBean.java index 34db8b4180..b9f47b3b2d 100644 --- a/src/java/org/apache/cassandra/service/StorageServiceMBean.java +++ b/src/java/org/apache/cassandra/service/StorageServiceMBean.java @@ -1170,18 +1170,6 @@ public interface StorageServiceMBean extends NotificationEmitter List getAccordManagedKeyspaces(); List getAccordManagedTables(); - /** Get the CMS commit member preference policy - * - * @return how to choose the cms member preference order for commits - */ - public String getCmsCommitMemberPreferencePolicy(); - - /** Update the CMS commit member preference policy - * - * @param policy see Config.CMSCommitMemberPreferencePolicy - */ - public void setCmsCommitMemberPreferencePolicy(String policy); - /** Gets the concurrency settings for processing stages*/ static class StageConcurrency implements Serializable {