diff --git a/hadoop-ozone/s3gateway/src/main/java/org/apache/hadoop/ozone/s3/endpoint/ObjectEndpoint.java b/hadoop-ozone/s3gateway/src/main/java/org/apache/hadoop/ozone/s3/endpoint/ObjectEndpoint.java index f695fcba55b..6f0ea57e862 100644 --- a/hadoop-ozone/s3gateway/src/main/java/org/apache/hadoop/ozone/s3/endpoint/ObjectEndpoint.java +++ b/hadoop-ozone/s3gateway/src/main/java/org/apache/hadoop/ozone/s3/endpoint/ObjectEndpoint.java @@ -515,6 +515,12 @@ private Response createMultipartKey(String bucket, String key, long length, OzoneBucket ozoneBucket = getBucket(bucket); String copyHeader; OzoneOutputStream ozoneOutputStream = null; + + if ("STREAMING-AWS4-HMAC-SHA256-PAYLOAD" + .equals(headers.getHeaderString("x-amz-content-sha256"))) { + body = new SignedChunksInputStream(body); + } + try { ozoneOutputStream = ozoneBucket.createMultipartKey( key, length, partNumber, uploadID);