Skip to content

Commit

Permalink
Use the index-name/shard-id path for uploading the segments
Browse files Browse the repository at this point in the history
  • Loading branch information
Sachin Kale committed Apr 20, 2022
1 parent 5196fb8 commit a6e05db
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -51,7 +51,8 @@ public class RemoteDirectoryFactory implements IndexStorePlugin.RemoteDirectoryF
public Directory newDirectory(IndexSettings indexSettings, ShardPath path, RepositoriesService repositoriesService) throws IOException {
Repository repository = repositoriesService.repository("dragon-stone");
BlobPath blobPath = new BlobPath();
blobPath.add("test-upload");
blobPath = blobPath.add(indexSettings.getIndex().getName());
blobPath = blobPath.add(String.valueOf(path.getShardId()));
BlobContainer blobContainer = ((BlobStoreRepository) repository).blobStore().blobContainer(blobPath);
return new RemoteDirectory(blobContainer);
}
Expand Down

0 comments on commit a6e05db

Please sign in to comment.