diff --git a/fluss-server/src/main/java/org/apache/fluss/server/log/remote/RemoteLogManager.java b/fluss-server/src/main/java/org/apache/fluss/server/log/remote/RemoteLogManager.java index f57a6ea81c..7ccf252f1c 100644 --- a/fluss-server/src/main/java/org/apache/fluss/server/log/remote/RemoteLogManager.java +++ b/fluss-server/src/main/java/org/apache/fluss/server/log/remote/RemoteLogManager.java @@ -124,7 +124,7 @@ public RemoteLogManager( this.coordinatorGateway = coordinatorGateway; this.logManager = logManager; this.remoteLogIndexCachesByDir = new ConcurrentHashMap<>(); - int cacheSize = (int) conf.get(ConfigOptions.REMOTE_LOG_INDEX_FILE_CACHE_SIZE).getBytes(); + long cacheSize = conf.get(ConfigOptions.REMOTE_LOG_INDEX_FILE_CACHE_SIZE).getBytes(); for (File dataDir : localDiskManager.dataDirs()) { remoteLogIndexCachesByDir.put( dataDir, new RemoteLogIndexCache(cacheSize, remoteLogStorage, dataDir));