@@ -1103,6 +1103,7 @@ private RewriteResponse rewrite(RewriteRequest req, String token) {
1103
1103
1104
1104
Long maxBytesRewrittenPerCall =
1105
1105
req .megabytesRewrittenPerCall != null ? req .megabytesRewrittenPerCall * MEGABYTE : null ;
1106
+ StorageObject content = req .overrideInfo ? req .target : null ;
1106
1107
Storage .Objects .Rewrite rewrite =
1107
1108
storage
1108
1109
.objects ()
@@ -1111,7 +1112,7 @@ private RewriteResponse rewrite(RewriteRequest req, String token) {
1111
1112
req .source .getName (),
1112
1113
req .target .getBucket (),
1113
1114
req .target .getName (),
1114
- req . overrideInfo ? req . target : null )
1115
+ content )
1115
1116
.setSourceGeneration (req .source .getGeneration ())
1116
1117
.setRewriteToken (token )
1117
1118
.setMaxBytesRewrittenPerCall (maxBytesRewrittenPerCall )
@@ -1132,6 +1133,7 @@ private RewriteResponse rewrite(RewriteRequest req, String token) {
1132
1133
.setDestinationPredefinedAcl (Option .PREDEFINED_ACL .getString (req .targetOptions ))
1133
1134
.setUserProject (userProject )
1134
1135
.setDestinationKmsKeyName (Option .KMS_KEY_NAME .getString (req .targetOptions ));
1136
+ rewrite .setDisableGZipContent (content == null );
1135
1137
HttpHeaders requestHeaders = rewrite .getRequestHeaders ();
1136
1138
setEncryptionHeaders (requestHeaders , SOURCE_ENCRYPTION_KEY_PREFIX , req .sourceOptions );
1137
1139
setEncryptionHeaders (requestHeaders , ENCRYPTION_KEY_PREFIX , req .targetOptions );
@@ -1460,6 +1462,7 @@ public HmacKey createHmacKey(String serviceAccountEmail, Map<Option, ?> options)
1460
1462
.hmacKeys ()
1461
1463
.create (projectId , serviceAccountEmail )
1462
1464
.setUserProject (Option .USER_PROJECT .getString (options ))
1465
+ .setDisableGZipContent (true )
1463
1466
.execute ();
1464
1467
} catch (IOException ex ) {
1465
1468
span .setStatus (Status .UNKNOWN .withDescription (ex .getMessage ()));
@@ -1714,6 +1717,7 @@ public Bucket lockRetentionPolicy(Bucket bucket, Map<Option, ?> options) {
1714
1717
.buckets ()
1715
1718
.lockRetentionPolicy (bucket .getName (), Option .IF_METAGENERATION_MATCH .getLong (options ))
1716
1719
.setUserProject (Option .USER_PROJECT .getString (options ))
1720
+ .setDisableGZipContent (true )
1717
1721
.execute ();
1718
1722
} catch (IOException ex ) {
1719
1723
span .setStatus (Status .UNKNOWN .withDescription (ex .getMessage ()));
0 commit comments