diff --git a/x-pack/plugin/blob-cache/src/main/java/org/elasticsearch/blobcache/shared/SharedBlobCacheService.java b/x-pack/plugin/blob-cache/src/main/java/org/elasticsearch/blobcache/shared/SharedBlobCacheService.java index a2ea3cf906aa6..d5daace4fa50a 100644 --- a/x-pack/plugin/blob-cache/src/main/java/org/elasticsearch/blobcache/shared/SharedBlobCacheService.java +++ b/x-pack/plugin/blob-cache/src/main/java/org/elasticsearch/blobcache/shared/SharedBlobCacheService.java @@ -768,8 +768,8 @@ void populate( if (gaps.isEmpty() == false) { final var cacheFileRegion = CacheFileRegion.this; for (SparseFileTracker.Gap gap : gaps) { - var fillGap = fillGap(cacheFileRegion, writer, gap); - executor.execute(ActionRunnable.run(refs.acquire(), fillGap::run)); + var fillGapRunnable = fillGapRunnable(cacheFileRegion, writer, gap); + executor.execute(ActionRunnable.run(refs.acquire(), fillGapRunnable::run)); } } } @@ -815,7 +815,7 @@ void populateAndRead( if (gaps.isEmpty() == false) { final var cacheFileRegion = CacheFileRegion.this; for (SparseFileTracker.Gap gap : gaps) { - executor.execute(fillGap(cacheFileRegion, writer, gap)); + executor.execute(fillGapRunnable(cacheFileRegion, writer, gap)); } } } catch (Exception e) { @@ -823,7 +823,7 @@ void populateAndRead( } } - private AbstractRunnable fillGap(CacheFileRegion cacheFileRegion, RangeMissingHandler writer, SparseFileTracker.Gap gap) { + private AbstractRunnable fillGapRunnable(CacheFileRegion cacheFileRegion, RangeMissingHandler writer, SparseFileTracker.Gap gap) { return new AbstractRunnable() { @Override protected void doRun() throws Exception {