Fix test failures

rayshrey · rayshrey · commit e280fe6513c7 · 2025-07-04T10:58:55.000+05:30
Signed-off-by: Shreyansh Ray &lt;rayshrey@amazon.com&gt;
diff --git a/server/src/main/java/org/opensearch/index/store/remote/utils/TransferManager.java b/server/src/main/java/org/opensearch/index/store/remote/utils/TransferManager.java
@@ -76,7 +76,8 @@ public IndexInput fetchBlob(BlobFetchRequest blobFetchRequest) throws IOExceptio
             return AccessController.doPrivileged((PrivilegedExceptionAction<IndexInput>) () -> {
                 CachedIndexInput cacheEntry = fileCache.get(key);
                 if (cacheEntry == null || cacheEntry.isClosed()) {
-                    cacheEntry = fileCache.put(key, new DelayedCreationCachedIndexInput(fileCache, streamReader, blobFetchRequest));
+                    cacheEntry = new DelayedCreationCachedIndexInput(fileCache, streamReader, blobFetchRequest);
+                    fileCache.put(key, cacheEntry);
                 }
 
                 // Cache entry was either retrieved from the cache or newly added, either

Original file line number	Diff line number	Diff line change
`@@ -76,7 +76,8 @@ public IndexInput fetchBlob(BlobFetchRequest blobFetchRequest) throws IOExceptio`
`76`	`76`	`return AccessController.doPrivileged((PrivilegedExceptionAction<IndexInput>) () -> {`
`77`	`77`	`CachedIndexInput cacheEntry = fileCache.get(key);`
`78`	`78`	`if (cacheEntry == null \|\| cacheEntry.isClosed()) {`
`79`		`- cacheEntry = fileCache.put(key, new DelayedCreationCachedIndexInput(fileCache, streamReader, blobFetchRequest));`
	`79`	`+ cacheEntry = new DelayedCreationCachedIndexInput(fileCache, streamReader, blobFetchRequest);`
	`80`	`+ fileCache.put(key, cacheEntry);`
`80`	`81`	`}`
`81`	`82`
`82`	`83`	`// Cache entry was either retrieved from the cache or newly added, either`