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 2018/01/09 17:31:31 UTC
ignite git commit: ignite-6814 Added detailed memory consumption
Repository: ignite
Updated Branches:
refs/heads/master 0234ee3bf -> cb20a2bfd
ignite-6814 Added detailed memory consumption
Signed-off-by: Andrey Gura <ag...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/cb20a2bf
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/cb20a2bf
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/cb20a2bf
Branch: refs/heads/master
Commit: cb20a2bfdf7383305b86da896fa0179bb965aeed
Parents: 0234ee3
Author: Slava Koptilin <sl...@gmail.com>
Authored: Tue Jan 9 20:31:06 2018 +0300
Committer: Andrey Gura <ag...@apache.org>
Committed: Tue Jan 9 20:31:06 2018 +0300
----------------------------------------------------------------------
.../ignite/internal/IgniteNodeAttributes.java | 3 +
.../discovery/GridDiscoveryManager.java | 92 ++++++++++++++++++--
.../pagemem/impl/PageMemoryNoStoreImpl.java | 14 +--
.../persistence/pagemem/PageMemoryImpl.java | 68 ++++++++++++++-
.../ignite/internal/util/IgniteUtils.java | 18 ++++
.../persistence/pagemem/PageMemoryImplTest.java | 16 +++-
6 files changed, 194 insertions(+), 17 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/cb20a2bf/modules/core/src/main/java/org/apache/ignite/internal/IgniteNodeAttributes.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/IgniteNodeAttributes.java b/modules/core/src/main/java/org/apache/ignite/internal/IgniteNodeAttributes.java
index 277ed79..c78773f 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/IgniteNodeAttributes.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/IgniteNodeAttributes.java
@@ -127,6 +127,9 @@ public final class IgniteNodeAttributes {
public static final String ATTR_OFFHEAP_SIZE = ATTR_PREFIX + ".offheap.size";
/** Internal attribute name constant. */
+ public static final String ATTR_DATA_REGIONS_OFFHEAP_SIZE = ATTR_PREFIX + ".data.regions.offheap.size";
+
+ /** Internal attribute name constant. */
public static final String ATTR_JVM_PID = ATTR_PREFIX + ".jvm.pid";
/** Internal attribute name constant. */
http://git-wip-us.apache.org/repos/asf/ignite/blob/cb20a2bf/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 6bb865d..faf222f 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
@@ -76,6 +76,7 @@ import org.apache.ignite.internal.processors.cache.DynamicCacheChangeRequest;
import org.apache.ignite.internal.processors.cache.DynamicCacheDescriptor;
import org.apache.ignite.internal.processors.cache.GridCacheAdapter;
import org.apache.ignite.internal.processors.cache.GridCacheContext;
+import org.apache.ignite.internal.processors.cache.persistence.DataRegion;
import org.apache.ignite.internal.processors.cache.persistence.GridCacheDatabaseSharedManager;
import org.apache.ignite.internal.processors.cluster.ChangeGlobalStateFinishMessage;
import org.apache.ignite.internal.processors.cluster.ChangeGlobalStateMessage;
@@ -98,8 +99,10 @@ import org.apache.ignite.internal.util.typedef.P1;
import org.apache.ignite.internal.util.typedef.internal.CU;
import org.apache.ignite.internal.util.typedef.internal.LT;
import org.apache.ignite.internal.util.typedef.internal.S;
+import org.apache.ignite.internal.util.typedef.internal.SB;
import org.apache.ignite.internal.util.typedef.internal.U;
import org.apache.ignite.internal.util.worker.GridWorker;
+import org.apache.ignite.lang.IgniteClosure;
import org.apache.ignite.lang.IgniteFuture;
import org.apache.ignite.lang.IgniteInClosure;
import org.apache.ignite.lang.IgnitePredicate;
@@ -139,6 +142,7 @@ import static org.apache.ignite.events.EventType.EVT_NODE_JOINED;
import static org.apache.ignite.events.EventType.EVT_NODE_LEFT;
import static org.apache.ignite.events.EventType.EVT_NODE_METRICS_UPDATED;
import static org.apache.ignite.events.EventType.EVT_NODE_SEGMENTED;
+import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_DATA_REGIONS_OFFHEAP_SIZE;
import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_DEPLOYMENT_MODE;
import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_LATE_AFFINITY_ASSIGNMENT;
import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_MACS;
@@ -492,6 +496,7 @@ public class GridDiscoveryManager extends GridManagerAdapter<DiscoverySpi> {
ctx.addNodeAttribute(ATTR_PHY_RAM, totSysMemory);
ctx.addNodeAttribute(ATTR_OFFHEAP_SIZE, requiredOffheap());
+ ctx.addNodeAttribute(ATTR_DATA_REGIONS_OFFHEAP_SIZE, configuredOffheap());
DiscoverySpi spi = getSpi();
@@ -1477,9 +1482,16 @@ public class GridDiscoveryManager extends GridManagerAdapter<DiscoverySpi> {
int totalCpus = cpus(allNodes);
double heap = U.heapSize(allNodes, 2);
+ double offheap = U.offheapSize(allNodes, 2);
if (log.isQuiet())
- U.quiet(false, topologySnapshotMessage(topVer, srvNodes.size(), clientNodes.size(), totalCpus, heap));
+ topologySnapshotMessage(new IgniteClosure<String, Void>() {
+ @Override public Void apply(String msg) {
+ U.quiet(false, msg);
+
+ return null;
+ }
+ }, topVer, srvNodes.size(), clientNodes.size(), totalCpus, heap, offheap);
if (log.isDebugEnabled()) {
String dbg = "";
@@ -1519,11 +1531,18 @@ public class GridDiscoveryManager extends GridManagerAdapter<DiscoverySpi> {
dbg += ">>> Total number of CPUs: " + totalCpus + U.nl();
dbg += ">>> Total heap size: " + heap + "GB" + U.nl();
+ dbg += ">>> Total offheap size: " + offheap + "GB" + U.nl();
log.debug(dbg);
}
else if (log.isInfoEnabled())
- log.info(topologySnapshotMessage(topVer, srvNodes.size(), clientNodes.size(), totalCpus, heap));
+ topologySnapshotMessage(new IgniteClosure<String, Void>() {
+ @Override public Void apply(String msg) {
+ log.info(msg);
+
+ return null;
+ }
+ }, topVer, srvNodes.size(), clientNodes.size(), totalCpus, heap, offheap);
}
/**
@@ -1558,20 +1577,83 @@ public class GridDiscoveryManager extends GridManagerAdapter<DiscoverySpi> {
}
/**
+ * @return Configured data regions offheap memory in bytes.
+ */
+ private long configuredOffheap() {
+ DataStorageConfiguration memCfg = ctx.config().getDataStorageConfiguration();
+
+ if (memCfg == null)
+ return 0;
+
+ long res = memCfg.getDefaultDataRegionConfiguration().getMaxSize();
+
+ DataRegionConfiguration[] dataRegions = memCfg.getDataRegionConfigurations();
+
+ if (dataRegions != null) {
+ for (DataRegionConfiguration dataReg : dataRegions)
+ res += dataReg.getMaxSize();
+ }
+
+ return res;
+ }
+
+ /**
+ * @param regCfg Data region configuration.
+ * @return Data region message.
+ */
+ private String dataRegionConfigurationMessage(DataRegionConfiguration regCfg) {
+ if (regCfg == null)
+ return null;
+
+ SB m = new SB();
+
+ m.a(" ^-- ").a(regCfg.getName()).a(" [");
+ m.a("initSize=").a(U.readableSize(regCfg.getInitialSize(), false));
+ m.a(", maxSize=").a(U.readableSize(regCfg.getMaxSize(), false));
+ m.a(", persistenceEnabled=" + regCfg.isPersistenceEnabled()).a(']');
+
+ return m.toString();
+ }
+
+ /**
+ * @param clo Wrapper of logger.
* @param topVer Topology version.
* @param srvNodesNum Server nodes number.
* @param clientNodesNum Client nodes number.
* @param totalCpus Total cpu number.
* @param heap Heap size.
- * @return Topology snapshot message.
+ * @param offheap Offheap size.
*/
- private String topologySnapshotMessage(long topVer, int srvNodesNum, int clientNodesNum, int totalCpus, double heap) {
- return PREFIX + " [" +
+ private void topologySnapshotMessage(IgniteClosure<String, Void> clo, long topVer, int srvNodesNum,
+ int clientNodesNum, int totalCpus, double heap, double offheap) {
+ String summary = PREFIX + " [" +
(discoOrdered ? "ver=" + topVer + ", " : "") +
"servers=" + srvNodesNum +
", clients=" + clientNodesNum +
", CPUs=" + totalCpus +
+ ", offheap=" + offheap + "GB" +
", heap=" + heap + "GB]";
+
+ clo.apply(summary);
+
+ DataStorageConfiguration memCfg = ctx.config().getDataStorageConfiguration();
+
+ if (memCfg == null)
+ return;
+
+ clo.apply("Data Regions Configured:");
+ clo.apply(dataRegionConfigurationMessage(memCfg.getDefaultDataRegionConfiguration()));
+
+ DataRegionConfiguration[] dataRegions = memCfg.getDataRegionConfigurations();
+
+ if (dataRegions != null) {
+ for (int i = 0; i < dataRegions.length; ++i) {
+ String msg = dataRegionConfigurationMessage(dataRegions[i]);
+
+ if (msg != null)
+ clo.apply(msg);
+ }
+ }
}
/** {@inheritDoc} */
http://git-wip-us.apache.org/repos/asf/ignite/blob/cb20a2bf/modules/core/src/main/java/org/apache/ignite/internal/pagemem/impl/PageMemoryNoStoreImpl.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/pagemem/impl/PageMemoryNoStoreImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/pagemem/impl/PageMemoryNoStoreImpl.java
index 5b80722..88237ee 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/pagemem/impl/PageMemoryNoStoreImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/pagemem/impl/PageMemoryNoStoreImpl.java
@@ -289,12 +289,14 @@ public class PageMemoryNoStoreImpl implements PageMemory {
}
if (relPtr == INVALID_REL_PTR)
- throw new IgniteOutOfMemoryException("Not enough memory allocated " +
- "[policyName=" + dataRegionCfg.getName() +
- ", size=" + U.readableSize(dataRegionCfg.getMaxSize(), false) + ']' + U.nl() +
- "Consider increasing memory policy size, enabling evictions, adding more nodes to the cluster, " +
- "reducing number of backups or reducing model size."
-
+ throw new IgniteOutOfMemoryException("Out of memory in data region [" +
+ "name=" + dataRegionCfg.getName() +
+ ", initSize=" + U.readableSize(dataRegionCfg.getInitialSize(), false) +
+ ", maxSize=" + U.readableSize(dataRegionCfg.getMaxSize(), false) +
+ ", persistenceEnabled=" + dataRegionCfg.isPersistenceEnabled() + "] Try the following:" + U.nl() +
+ " ^-- Increase maximum off-heap memory size (DataRegionConfiguration.maxSize)" + U.nl() +
+ " ^-- Enable Ignite persistence (DataRegionConfiguration.persistenceEnabled)" + U.nl() +
+ " ^-- Enable eviction or expiration policies"
);
assert (relPtr & ~PageIdUtils.PAGE_IDX_MASK) == 0 : U.hexLong(relPtr & ~PageIdUtils.PAGE_IDX_MASK);
http://git-wip-us.apache.org/repos/asf/ignite/blob/cb20a2bf/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/pagemem/PageMemoryImpl.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/pagemem/PageMemoryImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/pagemem/PageMemoryImpl.java
index cffc101..044ce22 100755
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/pagemem/PageMemoryImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/pagemem/PageMemoryImpl.java
@@ -38,6 +38,8 @@ import java.util.concurrent.locks.ReentrantReadWriteLock;
import org.apache.ignite.IgniteCheckedException;
import org.apache.ignite.IgniteException;
import org.apache.ignite.IgniteLogger;
+import org.apache.ignite.configuration.DataRegionConfiguration;
+import org.apache.ignite.configuration.DataStorageConfiguration;
import org.apache.ignite.internal.IgniteInternalFuture;
import org.apache.ignite.internal.mem.DirectMemoryProvider;
import org.apache.ignite.internal.mem.DirectMemoryRegion;
@@ -499,6 +501,19 @@ public class PageMemoryImpl implements PageMemoryEx {
seg.loadedPages.put(cacheId, PageIdUtils.effectivePageId(pageId), relPtr, seg.partTag(cacheId, partId));
}
+ catch (IgniteOutOfMemoryException oom) {
+ DataRegionConfiguration dataRegionCfg = getDataRegionConfiguration();
+
+ throw (IgniteOutOfMemoryException) new IgniteOutOfMemoryException("Out of memory in data region [" +
+ "name=" + dataRegionCfg.getName() +
+ ", initSize=" + U.readableSize(dataRegionCfg.getInitialSize(), false) +
+ ", maxSize=" + U.readableSize(dataRegionCfg.getMaxSize(), false) +
+ ", persistenceEnabled=" + dataRegionCfg.isPersistenceEnabled() + "] Try the following:" + U.nl() +
+ " ^-- Increase maximum off-heap memory size (DataRegionConfiguration.maxSize)" + U.nl() +
+ " ^-- Enable Ignite persistence (DataRegionConfiguration.persistenceEnabled)" + U.nl() +
+ " ^-- Enable eviction or expiration policies"
+ ).initCause(oom);
+ }
finally {
seg.writeLock().unlock();
}
@@ -507,6 +522,31 @@ public class PageMemoryImpl implements PageMemoryEx {
return isTrackingPage ? allocatePage(cacheId, partId, flags) : pageId;
}
+ /**
+ * @return Data region configuration.
+ */
+ private DataRegionConfiguration getDataRegionConfiguration() {
+ DataStorageConfiguration memCfg = ctx.kernalContext().config().getDataStorageConfiguration();
+
+ assert memCfg != null;
+
+ String dataRegionName = memMetrics.getName();
+
+ if (memCfg.getDefaultDataRegionConfiguration().getName().equals(dataRegionName))
+ return memCfg.getDefaultDataRegionConfiguration();
+
+ DataRegionConfiguration[] dataRegions = memCfg.getDataRegionConfigurations();
+
+ if (dataRegions != null) {
+ for (DataRegionConfiguration reg : dataRegions) {
+ if (reg != null && reg.getName().equals(dataRegionName))
+ return reg;
+ }
+ }
+
+ return null;
+ }
+
/** {@inheritDoc} */
@Override public ByteBuffer pageBuffer(long pageAddr) {
return wrapPointer(pageAddr, pageSize());
@@ -1859,8 +1899,20 @@ public class PageMemoryImpl implements PageMemoryEx {
final int cap = loadedPages.capacity();
- if (acquiredPages() >= loadedPages.size())
- throw new IgniteOutOfMemoryException("Failed to evict page from segment (all pages are acquired).");
+ if (acquiredPages() >= loadedPages.size()) {
+ DataRegionConfiguration dataRegionCfg = getDataRegionConfiguration();
+
+ throw new IgniteOutOfMemoryException("Failed to evict page from segment (all pages are acquired)."
+ + U.nl() + "Out of memory in data region [" +
+ "name=" + dataRegionCfg.getName() +
+ ", initSize=" + U.readableSize(dataRegionCfg.getInitialSize(), false) +
+ ", maxSize=" + U.readableSize(dataRegionCfg.getMaxSize(), false) +
+ ", persistenceEnabled=" + dataRegionCfg.isPersistenceEnabled() + "] Try the following:" + U.nl() +
+ " ^-- Increase maximum off-heap memory size (DataRegionConfiguration.maxSize)" + U.nl() +
+ " ^-- Enable Ignite persistence (DataRegionConfiguration.persistenceEnabled)" + U.nl() +
+ " ^-- Enable eviction or expiration policies"
+ );
+ }
// With big number of random picked pages we may fall into infinite loop, because
// every time the same page may be found.
@@ -2025,6 +2077,8 @@ public class PageMemoryImpl implements PageMemoryEx {
prevAddr = addr;
}
+ DataRegionConfiguration dataRegionCfg = getDataRegionConfiguration();
+
throw new IgniteOutOfMemoryException("Failed to find a page for eviction [segmentCapacity=" + cap +
", loaded=" + loadedPages.size() +
", maxDirtyPages=" + maxDirtyPages +
@@ -2032,7 +2086,15 @@ public class PageMemoryImpl implements PageMemoryEx {
", cpPages=" + (segCheckpointPages == null ? 0 : segCheckpointPages.size()) +
", pinnedInSegment=" + pinnedCnt +
", failedToPrepare=" + failToPrepare +
- ']');
+ ']' + U.nl() + "Out of memory in data region [" +
+ "name=" + dataRegionCfg.getName() +
+ ", initSize=" + U.readableSize(dataRegionCfg.getInitialSize(), false) +
+ ", maxSize=" + U.readableSize(dataRegionCfg.getMaxSize(), false) +
+ ", persistenceEnabled=" + dataRegionCfg.isPersistenceEnabled() + "] Try the following:" + U.nl() +
+ " ^-- Increase maximum off-heap memory size (DataRegionConfiguration.maxSize)" + U.nl() +
+ " ^-- Enable Ignite persistence (DataRegionConfiguration.persistenceEnabled)" + U.nl() +
+ " ^-- Enable eviction or expiration policies"
+ );
}
/**
http://git-wip-us.apache.org/repos/asf/ignite/blob/cb20a2bf/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteUtils.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteUtils.java b/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteUtils.java
index 6fb19a1..ea7c6d2 100755
--- a/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteUtils.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteUtils.java
@@ -257,6 +257,7 @@ import static org.apache.ignite.events.EventType.EVT_NODE_METRICS_UPDATED;
import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_BUILD_DATE;
import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_BUILD_VER;
import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_CACHE;
+import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_DATA_REGIONS_OFFHEAP_SIZE;
import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_JVM_PID;
import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_MACS;
import static org.apache.ignite.internal.util.GridUnsafe.objectFieldOffset;
@@ -1235,6 +1236,23 @@ public abstract class IgniteUtils {
}
/**
+ * Gets total offheap size in GB rounded to specified precision.
+ *
+ * @param nodes Nodes.
+ * @param precision Precision.
+ * @return Total offheap size in GB.
+ */
+ public static double offheapSize(Iterable<ClusterNode> nodes, int precision) {
+ // In bytes.
+ double totalOffheap = 0.0;
+
+ for (ClusterNode n : nodesPerJvm(nodes))
+ totalOffheap += n.<Long>attribute(ATTR_DATA_REGIONS_OFFHEAP_SIZE);
+
+ return roundedHeapSize(totalOffheap, precision);
+ }
+
+ /**
* Returns one representative node for each JVM.
*
* @param nodes Nodes.
http://git-wip-us.apache.org/repos/asf/ignite/blob/cb20a2bf/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/pagemem/PageMemoryImplTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/pagemem/PageMemoryImplTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/pagemem/PageMemoryImplTest.java
index 92c5ad6..bcdc6bb 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/pagemem/PageMemoryImplTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/pagemem/PageMemoryImplTest.java
@@ -18,7 +18,9 @@
package org.apache.ignite.internal.processors.cache.persistence.pagemem;
import java.nio.ByteBuffer;
-import org.apache.ignite.configuration.DataRegionConfiguration;
+import java.util.Collections;
+import org.apache.ignite.configuration.DataStorageConfiguration;
+import org.apache.ignite.configuration.IgniteConfiguration;
import org.apache.ignite.internal.mem.DirectMemoryProvider;
import org.apache.ignite.internal.mem.IgniteOutOfMemoryException;
import org.apache.ignite.internal.mem.unsafe.UnsafeMemoryProvider;
@@ -28,8 +30,10 @@ import org.apache.ignite.internal.processors.cache.GridCacheSharedContext;
import org.apache.ignite.internal.processors.cache.persistence.CheckpointLockStateChecker;
import org.apache.ignite.internal.processors.cache.persistence.IgniteCacheDatabaseSharedManager;
import org.apache.ignite.internal.processors.cache.persistence.DataRegionMetricsImpl;
+import org.apache.ignite.internal.processors.plugin.IgnitePluginProcessor;
import org.apache.ignite.internal.util.lang.GridInClosure3X;
import org.apache.ignite.internal.util.typedef.CIX3;
+import org.apache.ignite.plugin.PluginProvider;
import org.apache.ignite.testframework.junits.GridTestKernalContext;
import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest;
import org.apache.ignite.testframework.junits.logger.GridTestLog4jLogger;
@@ -74,8 +78,14 @@ public class PageMemoryImplTest extends GridCommonAbstractTest {
DirectMemoryProvider provider = new UnsafeMemoryProvider(log);
+ IgniteConfiguration igniteCfg = new IgniteConfiguration();
+ igniteCfg.setDataStorageConfiguration(new DataStorageConfiguration());
+
+ GridTestKernalContext kernalCtx = new GridTestKernalContext(new GridTestLog4jLogger(), igniteCfg);
+ kernalCtx.add(new IgnitePluginProcessor(kernalCtx, igniteCfg, Collections.<PluginProvider>emptyList()));
+
GridCacheSharedContext<Object, Object> sharedCtx = new GridCacheSharedContext<>(
- new GridTestKernalContext(new GridTestLog4jLogger()),
+ kernalCtx,
null,
null,
null,
@@ -110,7 +120,7 @@ public class PageMemoryImplTest extends GridCommonAbstractTest {
return true;
}
},
- new DataRegionMetricsImpl(new DataRegionConfiguration()),
+ new DataRegionMetricsImpl(igniteCfg.getDataStorageConfiguration().getDefaultDataRegionConfiguration()),
false
);