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 <[email protected]>
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 <[email protected]>
---
.../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;
