wip

andrross · Sep 29, 2023 · 3b4872d · 3b4872d
1 parent 0a95bed
commit 3b4872d
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/server/src/main/java/org/opensearch/index/shard/IndexShard.java b/server/src/main/java/org/opensearch/index/shard/IndexShard.java
@@ -4886,9 +4886,10 @@ private String copySegmentFiles(
                     // WIP: Single segment download logic
                     final Path indexPath = store.shardPath() == null ? null : store.shardPath().resolveIndex();
                     for (String segment: toDownloadSegments){
-                        final PlainActionFuture<String> segmentListener = PlainActionFuture.newFuture();
-                        sourceRemoteDirectory.copyTo(segment, storeDirectory, indexPath, segmentListener);
-                        segmentListener.actionGet();
+//                        final PlainActionFuture<String> segmentListener = PlainActionFuture.newFuture();
+//                        sourceRemoteDirectory.copyTo(segment, storeDirectory, indexPath, segmentListener);
+//                        segmentListener.actionGet();
+                        storeDirectory.copyFrom(sourceRemoteDirectory, segment, segment, IOContext.DEFAULT);
                         if (targetRemoteDirectory != null) {
                             targetRemoteDirectory.copyFrom(storeDirectory, segment, segment, IOContext.DEFAULT);
                         }