From a0907541f61d4d3dd0582c291509069a86e00e1a Mon Sep 17 00:00:00 2001
From: zhangjunfan <zhangjunfan@qiyi.com>
Date: Wed, 22 Jul 2026 12:03:48 +0800
Subject: [PATCH] [server] prevent remote log cache size overflow

---
 .../org/apache/fluss/server/log/remote/RemoteLogManager.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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));