This is an automated email from the ASF dual-hosted git repository. bdeggleston pushed a commit to branch cep-45-mutation-tracking in repository https://gitbox.apache.org/repos/asf/cassandra.git
commit 9d1ccb990157a3db4b435b036d65a0b40c111f85 Author: Blake Eggleston <[email protected]> AuthorDate: Wed Jan 28 16:07:24 2026 -0800 ninja: use configured flush mode --- .../apache/cassandra/replication/MutationJournal.java | 16 ++++++++++++++-- 1 file changed, 14 insertions(+), 2 deletions(-) diff --git a/src/java/org/apache/cassandra/replication/MutationJournal.java b/src/java/org/apache/cassandra/replication/MutationJournal.java index 6568452699..1112e5d05b 100644 --- a/src/java/org/apache/cassandra/replication/MutationJournal.java +++ b/src/java/org/apache/cassandra/replication/MutationJournal.java @@ -30,6 +30,8 @@ import javax.annotation.Nullable; import com.google.common.annotations.VisibleForTesting; import com.google.common.base.Preconditions; +import org.apache.cassandra.config.Config; +import org.jctools.maps.NonBlockingHashMapLong; import accord.utils.Invariants; import org.agrona.collections.Long2LongHashMap; @@ -52,7 +54,6 @@ import org.apache.cassandra.schema.Schema; import org.apache.cassandra.schema.TableId; import org.apache.cassandra.utils.Crc; import org.apache.cassandra.utils.concurrent.Semaphore; -import org.jctools.maps.NonBlockingHashMapLong; import static org.apache.cassandra.utils.FBUtilities.getAvailableProcessors; @@ -353,7 +354,18 @@ public class MutationJournal @Override public FlushMode flushMode() { - return FlushMode.PERIODIC; + Config.CommitLogSync mode = DatabaseDescriptor.getCommitLogSync(); + switch (DatabaseDescriptor.getCommitLogSync()) + { + case batch: + return FlushMode.BATCH; + case periodic: + return FlushMode.PERIODIC; + case group: + return FlushMode.GROUP; + default: + throw new IllegalStateException("Unhandled flush mode: " + mode); + } } @Override --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
