Skip to content

Commit d0fc6ee

Browse files
committed
Fix naming
1 parent 219cf40 commit d0fc6ee

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

modules/repository-azure/src/main/java/org/elasticsearch/repositories/azure/AzureBlobStore.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -295,18 +295,18 @@ private void deleteListOfBlobs(AzureBlobServiceClient azureBlobServiceClient, It
295295
// We need to use a container-scoped BlobBatchClient, so the restype=container parameter
296296
// is sent, and we can support all SAS token types
297297
// See https://learn.microsoft.com/en-us/rest/api/storageservices/blob-batch?tabs=shared-access-signatures#authorization
298-
BlobBatchClient batchAsyncClient = new BlobBatchClientBuilder(
298+
BlobBatchClient batchClient = new BlobBatchClientBuilder(
299299
azureBlobServiceClient.getAsyncClient().getBlobContainerAsyncClient(container)
300300
).buildClient();
301301
while (blobNames.hasNext()) {
302-
final BlobBatch currentBatch = batchAsyncClient.getBlobBatch();
302+
final BlobBatch currentBatch = batchClient.getBlobBatch();
303303
int counter = 0;
304304
while (counter < MAX_ELEMENTS_PER_BATCH && blobNames.hasNext()) {
305305
currentBatch.deleteBlob(container, blobNames.next());
306306
counter++;
307307
}
308308
try {
309-
batchAsyncClient.submitBatch(currentBatch);
309+
batchClient.submitBatch(currentBatch);
310310
} catch (BlobBatchStorageException bbse) {
311311
final Iterable<BlobStorageException> batchExceptions = bbse.getBatchExceptions();
312312
for (BlobStorageException bse : batchExceptions) {

0 commit comments

Comments
 (0)