This is an automated email from the ASF dual-hosted git repository. sk0x50 pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/master by this push: new c165e64 IGNITE-12884 Extended debug output of restoring partition states. Fixes #7657 c165e64 is described below commit c165e6472ba5ab00594f0f7b6bbcb5051a5b6ede Author: Evgeny Stanilovskiy <stanilov...@gmail.com> AuthorDate: Wed Apr 15 03:35:10 2020 +0300 IGNITE-12884 Extended debug output of restoring partition states. Fixes #7657 Signed-off-by: Slava Koptilin <slava.kopti...@gmail.com> --- .../cache/persistence/GridCacheOffheapManager.java | 22 ++++++++++++++++------ 1 file changed, 16 insertions(+), 6 deletions(-) diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheOffheapManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheOffheapManager.java index 9898760..1e293e6 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheOffheapManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheOffheapManager.java @@ -509,20 +509,22 @@ public class GridCacheOffheapManager extends IgniteCacheOffheapManagerImpl imple for (int p = 0; p < grp.affinity().partitions(); p++) { Integer recoverState = partitionRecoveryStates.get(new GroupPartitionId(grp.groupId(), p)); + long startTime = U.currentTimeMillis(); + if (ctx.pageStore().exists(grp.groupId(), p)) { ctx.pageStore().ensure(grp.groupId(), p); if (ctx.pageStore().pages(grp.groupId(), p) <= 1) { if (log.isDebugEnabled()) log.debug("Skipping partition on recovery (pages less than 1) " + - "[grp=" + grp.cacheOrGroupName() + ", p=" + p + "]"); + "[grp=" + grp.cacheOrGroupName() + ", p=" + p + ']'); continue; } if (log.isDebugEnabled()) log.debug("Creating partition on recovery (exists in page store) " + - "[grp=" + grp.cacheOrGroupName() + ", p=" + p + "]"); + "[grp=" + grp.cacheOrGroupName() + ", p=" + p + ']'); processed++; @@ -553,7 +555,8 @@ public class GridCacheOffheapManager extends IgniteCacheOffheapManagerImpl imple if (log.isDebugEnabled()) log.debug("Restored partition state (from WAL) " + "[grp=" + grp.cacheOrGroupName() + ", p=" + p + ", state=" + part.state() + - ", updCntr=" + part.initialUpdateCounter() + "]"); + ", updCntr=" + part.initialUpdateCounter() + + ", size=" + part.fullSize() + ']'); } else { int stateId = io.getPartitionState(pageAddr); @@ -563,7 +566,8 @@ public class GridCacheOffheapManager extends IgniteCacheOffheapManagerImpl imple if (log.isDebugEnabled()) log.debug("Restored partition state (from page memory) " + "[grp=" + grp.cacheOrGroupName() + ", p=" + p + ", state=" + part.state() + - ", updCntr=" + part.initialUpdateCounter() + ", stateId=" + stateId + "]"); + ", updCntr=" + part.initialUpdateCounter() + ", stateId=" + stateId + + ", size=" + part.fullSize() + ']'); } } finally { @@ -588,13 +592,19 @@ public class GridCacheOffheapManager extends IgniteCacheOffheapManagerImpl imple if (log.isDebugEnabled()) log.debug("Restored partition state (from WAL) " + "[grp=" + grp.cacheOrGroupName() + ", p=" + p + ", state=" + part.state() + - ", updCntr=" + part.initialUpdateCounter() + "]"); + ", updCntr=" + part.initialUpdateCounter() + + ", size=" + part.fullSize() + ']'); } else { if (log.isDebugEnabled()) log.debug("Skipping partition on recovery (no page store OR wal state) " + - "[grp=" + grp.cacheOrGroupName() + ", p=" + p + "]"); + "[grp=" + grp.cacheOrGroupName() + ", p=" + p + ']'); } + + if (log.isDebugEnabled()) + log.debug("Finished restoring partition state " + + "[grp=" + grp.cacheOrGroupName() + ", p=" + p + + ", time=" + (U.currentTimeMillis() - startTime) + " ms]"); } partitionStatesRestored = true;