You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@paimon.apache.org by lz...@apache.org on 2026/02/06 03:52:13 UTC

(paimon) branch master updated: [core] Remove useless fileReadCount in CacheManager

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

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new 9ca80b30e9 [core] Remove useless fileReadCount in CacheManager
9ca80b30e9 is described below

commit 9ca80b30e919ba97f18ca334518a90232ca4caa1
Author: JingsongLi <ji...@gmail.com>
AuthorDate: Thu Feb 5 23:27:00 2026 +0800

    [core] Remove useless fileReadCount in CacheManager
---
 .../src/main/java/org/apache/paimon/io/cache/CacheManager.java        | 4 ----
 1 file changed, 4 deletions(-)

diff --git a/paimon-common/src/main/java/org/apache/paimon/io/cache/CacheManager.java b/paimon-common/src/main/java/org/apache/paimon/io/cache/CacheManager.java
index 486b59e6c7..f85354aa2b 100644
--- a/paimon-common/src/main/java/org/apache/paimon/io/cache/CacheManager.java
+++ b/paimon-common/src/main/java/org/apache/paimon/io/cache/CacheManager.java
@@ -44,8 +44,6 @@ public class CacheManager {
     private final Cache dataCache;
     private final Cache indexCache;
 
-    private int fileReadCount;
-
     @VisibleForTesting
     public CacheManager(MemorySize maxMemorySize) {
         this(Cache.CacheType.GUAVA, maxMemorySize, 0);
@@ -71,7 +69,6 @@ public class CacheManager {
             this.indexCache =
                     CacheBuilder.newBuilder(cacheType).maximumWeight(indexCacheSize).build();
         }
-        this.fileReadCount = 0;
         LOG.info(
                 "Initialize cache manager with data cache of {} and index cache of {}.",
                 dataCacheSize,
@@ -94,7 +91,6 @@ public class CacheManager {
                 cache.get(
                         key,
                         k -> {
-                            this.fileReadCount++;
                             try {
                                 return new Cache.CacheValue(
                                         MemorySegment.wrap(reader.read(key)), callback);