This is an automated email from the ASF dual-hosted git repository. bereng pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/cassandra.git
The following commit(s) were added to refs/heads/trunk by this push: new 70389abcf7 Bti shouldn't be available in compatibility mode 70389abcf7 is described below commit 70389abcf78d913ea77b81cf226b10439f8db385 Author: Bereng <berenguerbl...@gmail.com> AuthorDate: Tue Jun 6 12:37:56 2023 +0200 Bti shouldn't be available in compatibility mode Patch by Berenguer Blasi; reviewed by Andrés de la Peña for CASSANDRA-18569 --- .../cassandra/config/DatabaseDescriptor.java | 2 + .../cassandra/utils/StorageCompatibilityMode.java | 15 +++++- .../utils/StorageCompatibilityModeTest.java | 57 ++++++++++++++++++++++ 3 files changed, 72 insertions(+), 2 deletions(-) diff --git a/src/java/org/apache/cassandra/config/DatabaseDescriptor.java b/src/java/org/apache/cassandra/config/DatabaseDescriptor.java index 4171bc4887..843511f3b0 100644 --- a/src/java/org/apache/cassandra/config/DatabaseDescriptor.java +++ b/src/java/org/apache/cassandra/config/DatabaseDescriptor.java @@ -1424,6 +1424,8 @@ public class DatabaseDescriptor if (selectedFormat == null) throw new ConfigurationException(String.format("Selected sstable format '%s' is not available.", selectedFormatName)); + getStorageCompatibilityMode().validateSstableFormat(selectedFormat); + return selectedFormat; } diff --git a/src/java/org/apache/cassandra/utils/StorageCompatibilityMode.java b/src/java/org/apache/cassandra/utils/StorageCompatibilityMode.java index 60dcc55b3f..2969597c23 100644 --- a/src/java/org/apache/cassandra/utils/StorageCompatibilityMode.java +++ b/src/java/org/apache/cassandra/utils/StorageCompatibilityMode.java @@ -19,6 +19,9 @@ package org.apache.cassandra.utils; import org.apache.cassandra.config.DatabaseDescriptor; +import org.apache.cassandra.exceptions.ConfigurationException; +import org.apache.cassandra.io.sstable.format.SSTableFormat; +import org.apache.cassandra.io.sstable.format.bti.BtiFormat; /** * The mode of compatibility with older Cassandra versions. @@ -33,7 +36,7 @@ public enum StorageCompatibilityMode CASSANDRA_4(4), /** - * Use the storage formats of the current version, but dissabling features that are not compatible with any + * Use the storage formats of the current version, but disabling features that are not compatible with any * not-upgraded nodes in the cluster. Use this during rolling upgrades to a new major Cassandra version. Once all * nodes have been upgraded, you can set the compatibility to {@link #NONE}. */ @@ -42,7 +45,7 @@ public enum StorageCompatibilityMode /** * Don't try to be compatible with older versions. Data will be written with the most recent format, which might * prevent a rollback to previous Cassandra versions. Features that are not compatible with older nodes will be - * enabled, asuming that all nodes in the cluster are in the same major version as this node. + * enabled, assuming that all nodes in the cluster are in the same major version as this node. */ NONE(Integer.MAX_VALUE); @@ -67,4 +70,12 @@ public enum StorageCompatibilityMode { return this.major < major; } + + public void validateSstableFormat(SSTableFormat<?, ?> selectedFormat) + { + if (selectedFormat.name().equals(BtiFormat.NAME) && this == StorageCompatibilityMode.CASSANDRA_4) + throw new ConfigurationException(String.format("Selected sstable format '%s' is not available when in storage compatibility mode '%s'.", + selectedFormat.name(), + this)); + } } diff --git a/test/unit/org/apache/cassandra/utils/StorageCompatibilityModeTest.java b/test/unit/org/apache/cassandra/utils/StorageCompatibilityModeTest.java new file mode 100644 index 0000000000..f8684edd62 --- /dev/null +++ b/test/unit/org/apache/cassandra/utils/StorageCompatibilityModeTest.java @@ -0,0 +1,57 @@ +/* +* Licensed to the Apache Software Foundation (ASF) under one +* or more contributor license agreements. See the NOTICE file +* distributed with this work for additional information +* regarding copyright ownership. The ASF licenses this file +* to you under the Apache License, Version 2.0 (the +* "License"); you may not use this file except in compliance +* with the License. You may obtain a copy of the License at +* +* http://www.apache.org/licenses/LICENSE-2.0 +* +* Unless required by applicable law or agreed to in writing, +* software distributed under the License is distributed on an +* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY +* KIND, either express or implied. See the License for the +* specific language governing permissions and limitations +* under the License. +*/ +package org.apache.cassandra.utils; + +import org.junit.Test; + +import org.apache.cassandra.exceptions.ConfigurationException; +import org.apache.cassandra.io.sstable.format.SSTableFormat; +import org.apache.cassandra.io.sstable.format.big.BigFormat; +import org.apache.cassandra.io.sstable.format.bti.BtiFormat; +import org.assertj.core.api.Assertions; + +public class StorageCompatibilityModeTest +{ + @Test + public void testBtiFormatAndStorageCompatibilityMode() + { + SSTableFormat<?, ?> big = new BigFormat(null); + SSTableFormat<?, ?> trie = new BtiFormat(null); + + for (StorageCompatibilityMode mode : StorageCompatibilityMode.values()) + { + switch (mode) + { + case UPGRADING: + case NONE: + mode.validateSstableFormat(big); + mode.validateSstableFormat(trie); + break; + case CASSANDRA_4: + mode.validateSstableFormat(big); + Assertions.assertThatThrownBy(() -> mode.validateSstableFormat(trie)) + .isInstanceOf(ConfigurationException.class) + .hasMessageContaining("is not available when in storage compatibility mode"); + break; + default: + throw new AssertionError("Undefined behaviour for mode " + mode); + } + } + } +} --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org For additional commands, e-mail: commits-h...@cassandra.apache.org