Skip to content

Commit a24cdc6

Browse files
committed
Disable gzip compression for exchanged pages
1 parent 7f0d189 commit a24cdc6

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

core/trino-main/src/main/java/io/trino/operator/HttpPageBufferClient.java

+2
Original file line numberDiff line numberDiff line change
@@ -60,6 +60,7 @@
6060
import static com.google.common.base.MoreObjects.toStringHelper;
6161
import static com.google.common.base.Preconditions.checkState;
6262
import static com.google.common.base.Strings.isNullOrEmpty;
63+
import static com.google.common.net.HttpHeaders.CONTENT_ENCODING;
6364
import static com.google.common.net.HttpHeaders.CONTENT_TYPE;
6465
import static io.airlift.http.client.HttpStatus.NO_CONTENT;
6566
import static io.airlift.http.client.HttpStatus.familyForStatusCode;
@@ -359,6 +360,7 @@ private synchronized void sendGetResults()
359360
HttpResponseFuture<PagesResponse> resultFuture = httpClient.executeAsync(
360361
prepareGet()
361362
.setHeader(TRINO_MAX_SIZE, maxResponseSize.toString())
363+
.setHeader(CONTENT_ENCODING, "identity")
362364
.setUri(uri).build(),
363365
new PageResponseHandler(dataIntegrityVerification != DataIntegrityVerification.NONE));
364366

0 commit comments

Comments
 (0)