diff --git a/cassandra-five-zero-bridge/src/main/java/org/apache/cassandra/bridge/CdcBridgeImplementation.java b/cassandra-five-zero-bridge/src/main/java/org/apache/cassandra/bridge/CdcBridgeImplementation.java index 6062f8cc2..cfcea225b 100644 --- a/cassandra-five-zero-bridge/src/main/java/org/apache/cassandra/bridge/CdcBridgeImplementation.java +++ b/cassandra-five-zero-bridge/src/main/java/org/apache/cassandra/bridge/CdcBridgeImplementation.java @@ -67,7 +67,7 @@ protected static synchronized void setCDC(Path path, int commitLogSegmentSize, b DatabaseDescriptor.setCommitLogSyncGroupWindow(30); DatabaseDescriptor.setCommitLogSegmentSize(commitLogSegmentSize); DatabaseDescriptor.getRawConfig().commitlog_total_space = new DataStorageSpec.IntMebibytesBound(1024); - DatabaseDescriptor.setCommitLogWriteDiskAccessMode(Config.DiskAccessMode.direct); + DatabaseDescriptor.setCommitLogWriteDiskAccessMode(Config.DiskAccessMode.mmap); DatabaseDescriptor.setCDCTotalSpaceInMiB(1024); DatabaseDescriptor.setCommitLogSegmentMgrProvider((commitLog -> new CommitLogSegmentManagerCDC(commitLog, commitLogPath.toString()))); setup = true;