You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sk...@apache.org on 2020/04/15 00:38:44 UTC
[ignite] branch master updated: IGNITE-12884 Extended debug output
of restoring partition states. Fixes #7657
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 <st...@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 <sl...@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;