Fix

Tim-Brooks · Dec 12, 2024 · af68a83 · af68a83
1 parent d08af89
commit af68a83
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/...n/blob-cache/src/main/java/org/elasticsearch/blobcache/shared/SharedBlobCacheService.java b/...n/blob-cache/src/main/java/org/elasticsearch/blobcache/shared/SharedBlobCacheService.java
@@ -682,7 +682,8 @@ public void maybeFetchRegions(
                 if (streamFactory == null) {
                     for (Tuple<CacheFileRegion<KeyType>, RegionGaps> gapsToFetch : gaps) {
                         for (SparseFileTracker.Gap gap : gapsToFetch.v2().gaps()) {
-                            fetchExecutor.execute(gapsToFetch.v1().fillGapRunnable(gap, writer, null, regionsListener.acquire()));
+                            int offset = Math.toIntExact(gapsToFetch.v2().regionOffset());
+                            fetchExecutor.execute(gapsToFetch.v1().fillGapRunnable(offset, gap, writer, null, regionsListener.acquire()));
                         }
                     }
                 } else {
@@ -694,7 +695,7 @@ public void maybeFetchRegions(
                     ) {
                         ArrayList<Runnable> gapFillingTasks = new ArrayList<>();
                         for (Tuple<CacheFileRegion<KeyType>, RegionGaps> gapsToFetch : gaps) {
-                            int offset = (gapsToFetch.v1().regionKey.region() - firstRegion) * regionSize;
+                            int offset = Math.toIntExact(gapsToFetch.v2().regionOffset());
                             gapFillingTasks.addAll(
                                 gapsToFetch.v1()
                                     .gapFillingTasks(offset, writer, sequentialGapsListener, streamFactory, gapsToFetch.v2().gaps())