fix

vikasvb90 · Jul 18, 2023 · bbadfc1 · bbadfc1
1 parent a6b1a06
commit bbadfc1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/server/src/main/java/org/opensearch/index/translog/transfer/TranslogTransferManager.java b/server/src/main/java/org/opensearch/index/translog/transfer/TranslogTransferManager.java
@@ -186,7 +186,7 @@ private void downloadToFS(String fileName, Path location, String primaryTerm, Tr
             Files.delete(filePath);
         }
 
-        try (InputStream inputStream = transferService.downloadBlob(remoteBaseTransferPath.add(primaryTerm), fileName)) {
+        try (InputStream inputStream = transferService.downloadBlob(remoteDataTransferPath.add(primaryTerm), fileName)) {
             InputStream transferInputStream = inputStream;
             if (transferContentType == TransferContentType.DATA && cryptoManager != null) {
                 transferInputStream = cryptoManager.createDecryptingStream(inputStream);