You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ag...@apache.org on 2017/10/25 09:39:14 UTC
ignite git commit: IGNITE-6748 Moved checkpoint page buffer to data
region configuration
Repository: ignite
Updated Branches:
refs/heads/ignite-6748 [created] dd03b1462
IGNITE-6748 Moved checkpoint page buffer to data region configuration
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/dd03b146
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/dd03b146
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/dd03b146
Branch: refs/heads/ignite-6748
Commit: dd03b1462295c6ee5570e834243f3b5324af13ff
Parents: 93be8ea
Author: Alexey Goncharuk <al...@gmail.com>
Authored: Wed Oct 25 12:38:58 2017 +0300
Committer: Alexey Goncharuk <al...@gmail.com>
Committed: Wed Oct 25 12:38:58 2017 +0300
----------------------------------------------------------------------
.../configuration/DataRegionConfiguration.java | 34 +++++++++-
.../configuration/DataStorageConfiguration.java | 29 --------
.../org/apache/ignite/internal/IgnitionEx.java | 13 ++--
.../discovery/GridDiscoveryManager.java | 8 ++-
.../GridCacheDatabaseSharedManager.java | 71 +++++++-------------
.../utils/PlatformConfigurationUtils.java | 2 -
.../node/VisorDataStorageConfiguration.java | 1 -
.../node/VisorPersistentStoreConfiguration.java | 1 -
.../persistence/db/wal/IgnitePdsWalTlbTest.java | 7 +-
.../pagemem/PagesWriteThrottleSandboxTest.java | 2 +-
.../pagemem/PagesWriteThrottleSmokeTest.java | 2 +-
11 files changed, 74 insertions(+), 96 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/dd03b146/modules/core/src/main/java/org/apache/ignite/configuration/DataRegionConfiguration.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/configuration/DataRegionConfiguration.java b/modules/core/src/main/java/org/apache/ignite/configuration/DataRegionConfiguration.java
index 50edf5c..4ae87e3 100644
--- a/modules/core/src/main/java/org/apache/ignite/configuration/DataRegionConfiguration.java
+++ b/modules/core/src/main/java/org/apache/ignite/configuration/DataRegionConfiguration.java
@@ -129,6 +129,9 @@ public final class DataRegionConfiguration implements Serializable {
*/
private boolean persistenceEnabled = false;
+ /** Temporary buffer size for checkpoints in bytes. */
+ private long checkpointPageBufSize;
+
/**
* Gets data region name.
*
@@ -212,11 +215,11 @@ public final class DataRegionConfiguration implements Serializable {
/**
* Sets a path to the memory-mapped files.
*
- * @param swapFilePath A Path to the memory mapped file.
+ * @param swapPath A Path to the memory mapped file.
* @return {@code this} for chaining.
*/
- public DataRegionConfiguration setSwapPath(String swapFilePath) {
- this.swapPath = swapFilePath;
+ public DataRegionConfiguration setSwapPath(String swapPath) {
+ this.swapPath = swapPath;
return this;
}
@@ -403,4 +406,29 @@ public final class DataRegionConfiguration implements Serializable {
return this;
}
+
+ /**
+ * Gets amount of memory allocated for a checkpoint temporary buffer.
+ *
+ * @return Checkpoint page buffer size in bytes or {@code 0} for Ignite
+ * to choose the buffer size automatically.
+ */
+ public long getCheckpointPageBufferSize() {
+ return checkpointPageBufSize;
+ }
+
+ /**
+ * Sets amount of memory allocated for the checkpoint temporary buffer. The buffer is used to create temporary
+ * copies of pages that are being written to disk and being update in parallel while the checkpoint is in
+ * progress.
+ *
+ * @param checkpointPageBufSize Checkpoint page buffer size in bytes or {@code 0} for Ignite to
+ * choose the buffer size automatically.
+ * @return {@code this} for chaining.
+ */
+ public DataRegionConfiguration setCheckpointPageBufferSize(long checkpointPageBufSize) {
+ this.checkpointPageBufSize = checkpointPageBufSize;
+
+ return this;
+ }
}
http://git-wip-us.apache.org/repos/asf/ignite/blob/dd03b146/modules/core/src/main/java/org/apache/ignite/configuration/DataStorageConfiguration.java
----------------------------------------------------------------------
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 bd314ab..8202ef8 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
@@ -173,9 +173,6 @@ public class DataStorageConfiguration implements Serializable {
private long lockWaitTime = DFLT_LOCK_WAIT_TIME;
/** */
- private long checkpointPageBufSize;
-
- /** */
private int checkpointThreads = DFLT_CHECKPOINT_THREADS;
/** Checkpoint write order. */
@@ -425,32 +422,6 @@ public class DataStorageConfiguration implements Serializable {
}
/**
- * Gets amount of memory allocated for a checkpoint temporary buffer.
- *
- * @return Checkpoint page buffer size in bytes or {@code 0} for Ignite
- * to choose the buffer size automatically.
- */
- public long getCheckpointPageBufferSize() {
- return checkpointPageBufSize;
- }
-
- /**
- * Sets amount of memory allocated for the checkpoint temporary buffer. The buffer is used to create temporary
- * copies of pages that are being written to disk and being update in parallel while the checkpoint is in
- * progress.
- *
- * @param checkpointPageBufSize Checkpoint page buffer size in bytes or {@code 0} for Ignite to
- * choose the buffer size automatically.
- * @return {@code this} for chaining.
- */
- public DataStorageConfiguration setCheckpointPageBufferSize(long checkpointPageBufSize) {
- this.checkpointPageBufSize = checkpointPageBufSize;
-
- return this;
- }
-
-
- /**
* Gets a number of threads to use for the checkpoint purposes.
*
* @return Number of checkpoint threads.
http://git-wip-us.apache.org/repos/asf/ignite/blob/dd03b146/modules/core/src/main/java/org/apache/ignite/internal/IgnitionEx.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/IgnitionEx.java b/modules/core/src/main/java/org/apache/ignite/internal/IgnitionEx.java
index 36257e2..67c771b 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/IgnitionEx.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/IgnitionEx.java
@@ -2779,7 +2779,9 @@ public class IgnitionEx {
*/
private static void convertLegacyDataStorageConfigurationToNew(
IgniteConfiguration cfg) throws IgniteCheckedException {
- boolean persistenceEnabled = cfg.getPersistentStoreConfiguration() != null;
+ PersistentStoreConfiguration psCfg = cfg.getPersistentStoreConfiguration();
+
+ boolean persistenceEnabled = psCfg != null;
DataStorageConfiguration dsCfg = new DataStorageConfiguration();
@@ -2814,6 +2816,9 @@ public class IgnitionEx {
region.setSwapPath(mpc.getSwapFilePath());
region.setMetricsEnabled(mpc.isMetricsEnabled());
+ if (persistenceEnabled)
+ region.setCheckpointPageBufferSize(psCfg.getCheckpointingPageBufferSize());
+
if (mpc.getName() == null) {
throw new IgniteCheckedException(new IllegalArgumentException(
"User-defined MemoryPolicyConfiguration must have non-null and non-empty name."));
@@ -2829,7 +2834,8 @@ public class IgnitionEx {
}
if (!optionalDataRegions.isEmpty())
- dsCfg.setDataRegionConfigurations(optionalDataRegions.toArray(new DataRegionConfiguration[optionalDataRegions.size()]));
+ dsCfg.setDataRegionConfigurations(optionalDataRegions.toArray(
+ new DataRegionConfiguration[optionalDataRegions.size()]));
if (!customDfltPlc) {
if (!DFLT_MEM_PLC_DEFAULT_NAME.equals(memCfg.getDefaultMemoryPolicyName())) {
@@ -2848,10 +2854,7 @@ public class IgnitionEx {
}
if (persistenceEnabled) {
- PersistentStoreConfiguration psCfg = cfg.getPersistentStoreConfiguration();
-
dsCfg.setCheckpointFrequency(psCfg.getCheckpointingFrequency());
- dsCfg.setCheckpointPageBufferSize(psCfg.getCheckpointingPageBufferSize());
dsCfg.setCheckpointThreads(psCfg.getCheckpointingThreads());
dsCfg.setCheckpointWriteOrder(psCfg.getCheckpointWriteOrder());
dsCfg.setFileIOFactory(psCfg.getFileIOFactory());
http://git-wip-us.apache.org/repos/asf/ignite/blob/dd03b146/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java
index a3b157d..77b0622 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java
@@ -1543,14 +1543,16 @@ public class GridDiscoveryManager extends GridManagerAdapter<DiscoverySpi> {
DataRegionConfiguration[] dataRegions = memCfg.getDataRegionConfigurations();
if (dataRegions != null) {
- for (DataRegionConfiguration dataReg : dataRegions)
+ for (DataRegionConfiguration dataReg : dataRegions) {
res += dataReg.getMaxSize();
+
+ res += GridCacheDatabaseSharedManager.checkpointBufferSize(dataReg);
+ }
}
res += memCfg.getDefaultDataRegionConfiguration().getMaxSize();
- // Add persistence (if any).
- res += GridCacheDatabaseSharedManager.checkpointBufferSize(ctx.config());
+ res += GridCacheDatabaseSharedManager.checkpointBufferSize(memCfg.getDefaultDataRegionConfiguration());
return res;
}
http://git-wip-us.apache.org/repos/asf/ignite/blob/dd03b146/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java
index de3b60a..920af17 100755
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java
@@ -156,8 +156,14 @@ public class GridCacheDatabaseSharedManager extends IgniteCacheDatabaseSharedMan
/** */
public static final String IGNITE_PDS_CHECKPOINT_TEST_SKIP_SYNC = "IGNITE_PDS_CHECKPOINT_TEST_SKIP_SYNC";
- /** Default checkpointing page buffer size (may be adjusted by Ignite). */
- public static final Long DFLT_CHECKPOINTING_PAGE_BUFFER_SIZE = 256L * 1024 * 1024;
+ /** */
+ private static final long GB = 1024L * 1024 * 1024;
+
+ /** Minimum checkpointing page buffer size (may be adjusted by Ignite). */
+ public static final Long DFLT_MIN_CHECKPOINTING_PAGE_BUFFER_SIZE = GB / 4;
+
+ /** Default minimum checkpointing page buffer size (may be adjusted by Ignite). */
+ public static final Long DFLT_MAX_CHECKPOINTING_PAGE_BUFFER_SIZE = 2 * GB;
/** Skip sync. */
private final boolean skipSync = IgniteSystemProperties.getBoolean(IGNITE_PDS_CHECKPOINT_TEST_SKIP_SYNC);
@@ -249,9 +255,6 @@ public class GridCacheDatabaseSharedManager extends IgniteCacheDatabaseSharedMan
private long checkpointFreq;
/** */
- private long checkpointPageBufSize;
-
- /** */
private FilePageStoreManager storeMgr;
/** Checkpoint metadata directory ("cp"), contains files with checkpoint start and end */
@@ -408,56 +411,27 @@ public class GridCacheDatabaseSharedManager extends IgniteCacheDatabaseSharedMan
30_000,
new LinkedBlockingQueue<Runnable>()
);
-
- checkpointPageBufSize = checkpointBufferSize(cctx.kernalContext().config());
}
/**
* Get checkpoint buffer size for the given configuration.
*
- * @param cfg Configuration.
+ * @param regCfg Configuration.
* @return Checkpoint buffer size.
*/
- public static long checkpointBufferSize(IgniteConfiguration cfg) {
- DataStorageConfiguration persistenceCfg = cfg.getDataStorageConfiguration();
-
- if (persistenceCfg == null)
+ public static long checkpointBufferSize(DataRegionConfiguration regCfg) {
+ if (!regCfg.isPersistenceEnabled())
return 0L;
- long res = persistenceCfg.getCheckpointPageBufferSize();
+ long res = regCfg.getCheckpointPageBufferSize();
if (res == 0L) {
- res = DFLT_CHECKPOINTING_PAGE_BUFFER_SIZE;
-
- DataStorageConfiguration memCfg = cfg.getDataStorageConfiguration();
-
- assert memCfg != null;
-
- long totalSize = memCfg.getSystemRegionMaxSize();
-
- if (memCfg.getDataRegionConfigurations() == null)
- totalSize += DataStorageConfiguration.DFLT_DATA_REGION_MAX_SIZE;
- else {
- for (DataRegionConfiguration memPlc : memCfg.getDataRegionConfigurations()) {
- if (Long.MAX_VALUE - memPlc.getMaxSize() > totalSize)
- totalSize += memPlc.getMaxSize();
- else {
- totalSize = Long.MAX_VALUE;
-
- break;
- }
- }
-
- assert totalSize > 0;
- }
-
- // Limit the checkpoint page buffer size by 2GB.
- long dfltSize = 2 * 1024L * 1024L * 1024L;
-
- long adjusted = Math.min(totalSize / 4, dfltSize);
-
- if (res < adjusted)
- res = adjusted;
+ if (regCfg.getMaxSize() < GB)
+ res = Math.min(DFLT_MIN_CHECKPOINTING_PAGE_BUFFER_SIZE, regCfg.getMaxSize());
+ else if (regCfg.getMaxSize() < 8 * GB)
+ res = regCfg.getMaxSize() / 4;
+ else
+ res = DFLT_MAX_CHECKPOINTING_PAGE_BUFFER_SIZE;
}
return res;
@@ -689,13 +663,16 @@ public class GridCacheDatabaseSharedManager extends IgniteCacheDatabaseSharedMan
long cacheSize = plcCfg.getMaxSize();
// Checkpoint buffer size can not be greater than cache size, it does not make sense.
- long chpBufSize = Math.min(checkpointPageBufSize, cacheSize);
+ long chpBufSize = checkpointBufferSize(plcCfg);
- if (checkpointPageBufSize > cacheSize)
+ if (chpBufSize > cacheSize) {
U.quietAndInfo(log,
- "Checkpoint page buffer size is too big, setting to an adjusted cache size [size="
+ "Configured checkpoint page buffer size is too big, setting to the max region size [size="
+ U.readableSize(cacheSize, false) + ", memPlc=" + plcCfg.getName() + ']');
+ chpBufSize = cacheSize;
+ }
+
boolean writeThrottlingEnabled = persistenceCfg.isWriteThrottlingEnabled();
if (IgniteSystemProperties.getBoolean(IgniteSystemProperties.IGNITE_OVERRIDE_WRITE_THROTTLING_ENABLED, false))
http://git-wip-us.apache.org/repos/asf/ignite/blob/dd03b146/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformConfigurationUtils.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformConfigurationUtils.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformConfigurationUtils.java
index 981a231..b717650 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformConfigurationUtils.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformConfigurationUtils.java
@@ -1648,7 +1648,6 @@ public class PlatformConfigurationUtils {
DataStorageConfiguration res = new DataStorageConfiguration()
.setStoragePath(in.readString())
.setCheckpointFrequency(in.readLong())
- .setCheckpointPageBufferSize(in.readLong())
.setCheckpointThreads(in.readInt())
.setLockWaitTime((int) in.readLong())
.setWalHistorySize(in.readInt())
@@ -1743,7 +1742,6 @@ public class PlatformConfigurationUtils {
w.writeString(cfg.getStoragePath());
w.writeLong(cfg.getCheckpointFrequency());
- w.writeLong(cfg.getCheckpointPageBufferSize());
w.writeInt(cfg.getCheckpointThreads());
w.writeLong(cfg.getLockWaitTime());
w.writeInt(cfg.getWalHistorySize());
http://git-wip-us.apache.org/repos/asf/ignite/blob/dd03b146/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorDataStorageConfiguration.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorDataStorageConfiguration.java b/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorDataStorageConfiguration.java
index 78bf1c5..72d3c11 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorDataStorageConfiguration.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorDataStorageConfiguration.java
@@ -155,7 +155,6 @@ public class VisorDataStorageConfiguration extends VisorDataTransferObject {
storagePath = cfg.getStoragePath();
checkpointFreq = cfg.getCheckpointFrequency();
lockWaitTime = cfg.getLockWaitTime();
- checkpointPageBufSize = cfg.getCheckpointPageBufferSize();
checkpointThreads = cfg.getCheckpointThreads();
checkpointWriteOrder = cfg.getCheckpointWriteOrder();
walHistSize = cfg.getWalHistorySize();
http://git-wip-us.apache.org/repos/asf/ignite/blob/dd03b146/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorPersistentStoreConfiguration.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorPersistentStoreConfiguration.java b/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorPersistentStoreConfiguration.java
index f9d7a64..d26ab35 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorPersistentStoreConfiguration.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorPersistentStoreConfiguration.java
@@ -103,7 +103,6 @@ public class VisorPersistentStoreConfiguration extends VisorDataTransferObject {
persistenceStorePath = cfg.getStoragePath();
checkpointingFreq = cfg.getCheckpointFrequency();
lockWaitTime = cfg.getLockWaitTime();
- checkpointingPageBufSize = cfg.getCheckpointPageBufferSize();
checkpointingThreads = cfg.getCheckpointThreads();
walHistSize = cfg.getWalHistorySize();
walSegments = cfg.getWalSegments();
http://git-wip-us.apache.org/repos/asf/ignite/blob/dd03b146/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/db/wal/IgnitePdsWalTlbTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/db/wal/IgnitePdsWalTlbTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/db/wal/IgnitePdsWalTlbTest.java
index 5700eb3..3b76b63 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/db/wal/IgnitePdsWalTlbTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/db/wal/IgnitePdsWalTlbTest.java
@@ -31,7 +31,7 @@ import org.apache.ignite.spi.discovery.tcp.ipfinder.TcpDiscoveryIpFinder;
import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder;
import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest;
-import static org.apache.ignite.internal.processors.cache.persistence.GridCacheDatabaseSharedManager.DFLT_CHECKPOINTING_PAGE_BUFFER_SIZE;
+import static org.apache.ignite.internal.processors.cache.persistence.GridCacheDatabaseSharedManager.DFLT_MIN_CHECKPOINTING_PAGE_BUFFER_SIZE;
import static org.apache.ignite.internal.processors.cache.persistence.file.FilePageStoreManager.DFLT_STORE_DIR;
/**
@@ -54,9 +54,10 @@ public class IgnitePdsWalTlbTest extends GridCommonAbstractTest {
DataStorageConfiguration memCfg = new DataStorageConfiguration()
.setDefaultDataRegionConfiguration(
- new DataRegionConfiguration().setMaxSize(100 * 1024 * 1024).setPersistenceEnabled(true))
+ new DataRegionConfiguration().setMaxSize(100 * 1024 * 1024)
+ .setPersistenceEnabled(true)
+ .setCheckpointPageBufferSize(DFLT_MIN_CHECKPOINTING_PAGE_BUFFER_SIZE + 1))
.setWalMode(WALMode.LOG_ONLY)
- .setCheckpointPageBufferSize(DFLT_CHECKPOINTING_PAGE_BUFFER_SIZE + 1)
.setWalThreadLocalBufferSize(640000000);
cfg.setDataStorageConfiguration(memCfg);
http://git-wip-us.apache.org/repos/asf/ignite/blob/dd03b146/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/pagemem/PagesWriteThrottleSandboxTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/pagemem/PagesWriteThrottleSandboxTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/pagemem/PagesWriteThrottleSandboxTest.java
index 30fb492..9529f59 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/pagemem/PagesWriteThrottleSandboxTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/pagemem/PagesWriteThrottleSandboxTest.java
@@ -68,12 +68,12 @@ public class PagesWriteThrottleSandboxTest extends GridCommonAbstractTest {
DataStorageConfiguration dbCfg = new DataStorageConfiguration()
.setDefaultDataRegionConfiguration(new DataRegionConfiguration()
.setMaxSize(4000L * 1024 * 1024)
+ .setCheckpointPageBufferSize(1000L * 1000 * 1000)
.setName("dfltDataRegion")
.setMetricsEnabled(true)
.setPersistenceEnabled(true))
.setWalMode(WALMode.BACKGROUND)
.setCheckpointFrequency(20_000)
- .setCheckpointPageBufferSize(1000L * 1000 * 1000)
.setWriteThrottlingEnabled(true);
cfg.setDataStorageConfiguration(dbCfg);
http://git-wip-us.apache.org/repos/asf/ignite/blob/dd03b146/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/pagemem/PagesWriteThrottleSmokeTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/pagemem/PagesWriteThrottleSmokeTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/pagemem/PagesWriteThrottleSmokeTest.java
index ab7aab4..1875cfb 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/pagemem/PagesWriteThrottleSmokeTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/pagemem/PagesWriteThrottleSmokeTest.java
@@ -78,12 +78,12 @@ public class PagesWriteThrottleSmokeTest extends GridCommonAbstractTest {
DataStorageConfiguration dbCfg = new DataStorageConfiguration()
.setDefaultDataRegionConfiguration(new DataRegionConfiguration()
.setMaxSize(400 * 1024 * 1024)
+ .setCheckpointPageBufferSize(200 * 1000 * 1000)
.setName("dfltDataRegion")
.setMetricsEnabled(true)
.setPersistenceEnabled(true))
.setWalMode(WALMode.BACKGROUND)
.setCheckpointFrequency(20_000)
- .setCheckpointPageBufferSize(200 * 1000 * 1000)
.setWriteThrottlingEnabled(true)
.setCheckpointThreads(1)
.setFileIOFactory(new SlowCheckpointFileIOFactory());