This is an automated email from the ASF dual-hosted git repository.

timoninmaxim 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 f8cc3f86977 IGNITE-23451 Fix CachePartitionDefragmentationManager logs 
wrong old index size (#11607)
f8cc3f86977 is described below

commit f8cc3f869770d3ad1d1883e8bf622a9ee8b60cf9
Author: Alexander Chesnokov <[email protected]>
AuthorDate: Wed Oct 23 12:16:13 2024 +0300

    IGNITE-23451 Fix CachePartitionDefragmentationManager logs wrong old index 
size (#11607)
---
 .../defragmentation/CachePartitionDefragmentationManager.java          | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/defragmentation/CachePartitionDefragmentationManager.java
 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/defragmentation/CachePartitionDefragmentationManager.java
index bde4ac6bbfb..21b09474185 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/defragmentation/CachePartitionDefragmentationManager.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/defragmentation/CachePartitionDefragmentationManager.java
@@ -420,6 +420,7 @@ public class CachePartitionDefragmentationManager {
                     }
 
                     PageStore oldIdxPageStore = 
filePageStoreMgr.getStore(grpId, INDEX_PARTITION);
+                    long oldSize = oldIdxPageStore.size();
 
                     idxDfrgFut = idxDfrgFut.chain(() -> {
                         if (log.isDebugEnabled()) {
@@ -469,7 +470,7 @@ public class CachePartitionDefragmentationManager {
 
                     status.onIndexDefragmented(
                         oldGrpCtx,
-                        oldIdxPageStore.size(),
+                        oldSize,
                         pageSize + idxAllocationTracker.get() * pageSize // + 
file header.
                     );
                 }

Reply via email to