diff --git a/modules/core/src/main/java/org/apache/ignite/configuration/DataStorageConfiguration.java b/modules/core/src/main/java/org/apache/ignite/configuration/DataStorageConfiguration.java index acf94adf41f383..8daa97a1c7b642 100644 --- a/modules/core/src/main/java/org/apache/ignite/configuration/DataStorageConfiguration.java +++ b/modules/core/src/main/java/org/apache/ignite/configuration/DataStorageConfiguration.java @@ -250,7 +250,7 @@ public class DataStorageConfiguration implements Serializable { /** Change Data Capture directory size limit. */ @IgniteExperimental - private long cdcWalDirectoryMaxSize = DFLT_CDC_WAL_DIRECTORY_MAX_SIZE; + private long cdcWalDirMaxSize = DFLT_CDC_WAL_DIRECTORY_MAX_SIZE; /** * Metrics enabled flag. @@ -815,7 +815,7 @@ public DataStorageConfiguration setCdcWalPath(String cdcWalPath) { */ @IgniteExperimental public long getCdcWalDirectoryMaxSize() { - return cdcWalDirectoryMaxSize; + return cdcWalDirMaxSize; } /** @@ -824,12 +824,12 @@ public long getCdcWalDirectoryMaxSize() { * The CDC application will log an error due to a gap in wal files sequence. Note that cache changes will be lost. * Default is no limit. * - * @param cdcWalDirectoryMaxSize CDC directory maximum size in bytes. + * @param cdcWalDirMaxSize CDC directory maximum size in bytes. * @return {@code this} for chaining. */ @IgniteExperimental - public DataStorageConfiguration setCdcWalDirectoryMaxSize(long cdcWalDirectoryMaxSize) { - this.cdcWalDirectoryMaxSize = cdcWalDirectoryMaxSize; + public DataStorageConfiguration setCdcWalDirectoryMaxSize(long cdcWalDirMaxSize) { + this.cdcWalDirMaxSize = cdcWalDirMaxSize; return this; } diff --git a/modules/core/src/test/java/org/apache/ignite/cdc/CdcSelfTest.java b/modules/core/src/test/java/org/apache/ignite/cdc/CdcSelfTest.java index 7102bec42299cd..f51202989fe404 100644 --- a/modules/core/src/test/java/org/apache/ignite/cdc/CdcSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/cdc/CdcSelfTest.java @@ -105,7 +105,7 @@ public class CdcSelfTest extends AbstractCdcTest { public boolean persistenceEnabled; /** */ - private long cdcWalDirectoryMaxSize = DFLT_CDC_WAL_DIRECTORY_MAX_SIZE; + private long cdcWalDirMaxSize = DFLT_CDC_WAL_DIRECTORY_MAX_SIZE; /** */ @Parameterized.Parameters(name = "consistentId={0}, wal={1}, persistence={2}") @@ -134,7 +134,7 @@ public static Collection parameters() { .setPersistenceEnabled(persistenceEnabled) .setCdcEnabled(true)) .setWalArchivePath(DFLT_WAL_ARCHIVE_PATH + "/" + U.maskForFileName(igniteInstanceName)) - .setCdcWalDirectoryMaxSize(cdcWalDirectoryMaxSize)); + .setCdcWalDirectoryMaxSize(cdcWalDirMaxSize)); cfg.setCacheConfiguration( new CacheConfiguration<>(TX_CACHE_NAME) @@ -742,8 +742,8 @@ public void testDisable() throws Exception { /** */ @Test public void testCdcDirectoryMaxSize() throws Exception { - cdcWalDirectoryMaxSize = 10 * U.MB; - int segmentSize = (int)(cdcWalDirectoryMaxSize / 2); + cdcWalDirMaxSize = 10 * U.MB; + int segmentSize = (int)(cdcWalDirMaxSize / 2); IgniteEx ign = startGrid(0); @@ -772,7 +772,7 @@ public void testCdcDirectoryMaxSize() throws Exception { // The segment link creation should be skipped. writeSgmnt.run(); - assertTrue(cdcWalDirectoryMaxSize >= Arrays.stream(walCdcDir.listFiles()).mapToLong(File::length).sum()); + assertTrue(cdcWalDirMaxSize >= Arrays.stream(walCdcDir.listFiles()).mapToLong(File::length).sum()); ListeningTestLogger lsnLog = new ListeningTestLogger(log);