diff --git a/src/main/java/org/gaul/s3proxy/azureblob/AzureBlobStore.java b/src/main/java/org/gaul/s3proxy/azureblob/AzureBlobStore.java index 49ed0b7..4cf3505 100644 --- a/src/main/java/org/gaul/s3proxy/azureblob/AzureBlobStore.java +++ b/src/main/java/org/gaul/s3proxy/azureblob/AzureBlobStore.java @@ -370,9 +370,8 @@ public final class AzureBlobStore extends BaseBlobStore { .getBlockBlobClient(); var blockId = makeBlockId(partNumber); var length = payload.getContentMetadata().getContentLength(); - try (var is = payload.openStream(); - var os = client.getBlobOutputStream(/*overwrite=*/ true)) { - is.transferTo(os); + try (var is = payload.openStream()) { + client.stageBlock(blockId, is, length); } catch (IOException ioe) { throw new RuntimeException(ioe); }