This is an automated email from the ASF dual-hosted git repository.
tkalkirill pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
The following commit(s) were added to refs/heads/main by this push:
new 873ac61c503 IGNITE-26732 Improve logging of written dirty pages count
for aipersist (#6791)
873ac61c503 is described below
commit 873ac61c503b1facb830499fa189639c1ab66ba5
Author: Kirill Tkalenko <[email protected]>
AuthorDate: Thu Oct 16 12:07:49 2025 +0300
IGNITE-26732 Improve logging of written dirty pages count for aipersist
(#6791)
---
.../internal/pagememory/persistence/checkpoint/Checkpointer.java | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
diff --git
a/modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/checkpoint/Checkpointer.java
b/modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/checkpoint/Checkpointer.java
index 0d331a17e74..cd7dfe3afc5 100644
---
a/modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/checkpoint/Checkpointer.java
+++
b/modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/checkpoint/Checkpointer.java
@@ -120,7 +120,7 @@ public class Checkpointer extends IgniteWorker {
private static final String CHECKPOINT_FINISHED_LOG_TEMPLATE = "Checkpoint
finished ["
+ "checkpointId={}, "
- + "pages={}, "
+ + "writtenPages={}, "
+ "pagesWriteTime={}ms, "
+ "fsyncTime={}ms, "
+ "replicatorLogSyncTime={}ms, "
@@ -424,13 +424,14 @@ public class Checkpointer extends IgniteWorker {
if (chp.hasDelta()) {
if (log.isInfoEnabled()) {
- long totalWriteBytes = (long) pageSize *
chp.dirtyPagesSize;
+ int totalWrittenPages = chp.progress.writtenPages();
+ long totalWriteBytes = (long) pageSize * totalWrittenPages;
long totalDurationInNanos =
tracker.checkpointDuration(NANOSECONDS);
log.info(
CHECKPOINT_FINISHED_LOG_TEMPLATE,
chp.progress.id(),
- chp.dirtyPagesSize,
+ totalWrittenPages,
tracker.pagesWriteDuration(MILLISECONDS),
tracker.fsyncDuration(MILLISECONDS),
tracker.replicatorLogSyncDuration(MILLISECONDS),
