diff --git a/priam/src/main/java/com/netflix/priam/aws/S3FileSystem.java b/priam/src/main/java/com/netflix/priam/aws/S3FileSystem.java index a8237d754..bf52d2da1 100644 --- a/priam/src/main/java/com/netflix/priam/aws/S3FileSystem.java +++ b/priam/src/main/java/com/netflix/priam/aws/S3FileSystem.java @@ -138,7 +138,7 @@ private Map getFileMetadata(File file) { private long uploadMultipart(AbstractBackupPath path, Instant target) throws BackupRestoreException { - if (config.useReusableBufferForMultipartUploads()) { + if (config.useReusableBufferForMultipartUploads() && path.getCompression() == CompressionType.NONE) { return uploadMultipartWithBuffers(path, target); } else { return uploadMultipartLegacy(path, target); @@ -355,7 +355,7 @@ protected long uploadFileImpl(AbstractBackupPath path, Instant target) if (localFile.length() >= config.getBackupChunkSize()) return uploadMultipart(path, target); - if (config.useReusableBufferForMultipartUploads()) { + if (config.useReusableBufferForMultipartUploads() && path.getCompression() == CompressionType.NONE) { return uploadFileWithByteBuffer(path, target); } else { return uploadFileWithByteArray(path, target);