Use the unsafe future for read single region

We need to use the unsafe future to block on the same thread pool similar to read multi regions.
Tim-Brooks · May 28, 2024 · 486cfb8 · 486cfb8
1 parent f73fedc
commit 486cfb8
Showing 1 changed file with 3 additions and 1 deletion.
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
@@ -1116,7 +1116,9 @@ private int readSingleRegion(
             RangeMissingHandler writer,
             int region
         ) throws InterruptedException, ExecutionException {
-            final PlainActionFuture<Integer> readFuture = new PlainActionFuture<>();
+            final PlainActionFuture<Integer> readFuture =  new UnsafePlainActionFuture<>(
+                BlobStoreRepository.STATELESS_SHARD_PREWARMING_THREAD_NAME
+            );
             final CacheFileRegion fileRegion = get(cacheKey, length, region);
             final long regionStart = getRegionStart(region);
             fileRegion.populateAndRead(