diff --git a/docs/content/toc.md b/docs/content/toc.md index 5d67c19a5708..eb82d2f3d3e2 100644 --- a/docs/content/toc.md +++ b/docs/content/toc.md @@ -135,6 +135,7 @@ layout: toc * [Recommendations](/docs/VERSION/operations/recommendations.html) * [TLS Support](/docs/VERSION/operations/tls-support.html) * [Password Provider](/docs/VERSION/operations/password-provider.html) + * [HTTP Compression](/docs/VERSION/operations/http-compression.html) ## Configuration * [Configuration Reference](/docs/VERSION/configuration/index.html) diff --git a/server/src/test/java/org/apache/druid/server/AsyncManagementForwardingServletTest.java b/server/src/test/java/org/apache/druid/server/AsyncManagementForwardingServletTest.java index 05546864c8a3..804a8f5fbde4 100644 --- a/server/src/test/java/org/apache/druid/server/AsyncManagementForwardingServletTest.java +++ b/server/src/test/java/org/apache/druid/server/AsyncManagementForwardingServletTest.java @@ -36,6 +36,7 @@ import org.apache.druid.initialization.Initialization; import org.apache.druid.java.util.common.StringUtils; import org.apache.druid.server.initialization.BaseJettyTest; +import org.apache.druid.server.initialization.ServerConfig; import org.apache.druid.server.initialization.jetty.JettyServerInitUtils; import org.apache.druid.server.initialization.jetty.JettyServerInitializer; import org.eclipse.jetty.client.HttpClient; @@ -61,6 +62,7 @@ import java.net.URL; import java.nio.charset.StandardCharsets; import java.util.Map; +import java.util.zip.Deflater; public class AsyncManagementForwardingServletTest extends BaseJettyTest { @@ -438,7 +440,12 @@ public String getCurrentLeader() JettyServerInitUtils.addExtensionFilters(root, injector); final HandlerList handlerList = new HandlerList(); - handlerList.setHandlers(new Handler[]{JettyServerInitUtils.wrapWithDefaultGzipHandler(root, 4096, -1)}); + handlerList.setHandlers( + new Handler[]{JettyServerInitUtils.wrapWithDefaultGzipHandler( + root, + ServerConfig.DEFAULT_GZIP_INFLATE_BUFFER_SIZE, + Deflater.DEFAULT_COMPRESSION)} + ); server.setHandler(handlerList); } } diff --git a/server/src/test/java/org/apache/druid/server/AsyncQueryForwardingServletTest.java b/server/src/test/java/org/apache/druid/server/AsyncQueryForwardingServletTest.java index 362948f17414..7cff40004ce7 100644 --- a/server/src/test/java/org/apache/druid/server/AsyncQueryForwardingServletTest.java +++ b/server/src/test/java/org/apache/druid/server/AsyncQueryForwardingServletTest.java @@ -49,6 +49,7 @@ import org.apache.druid.query.timeseries.TimeseriesQuery; import org.apache.druid.segment.TestHelper; import org.apache.druid.server.initialization.BaseJettyTest; +import org.apache.druid.server.initialization.ServerConfig; import org.apache.druid.server.initialization.jetty.JettyServerInitUtils; import org.apache.druid.server.initialization.jetty.JettyServerInitializer; import org.apache.druid.server.log.NoopRequestLogger; @@ -84,6 +85,7 @@ import java.util.Collection; import java.util.concurrent.CountDownLatch; import java.util.concurrent.atomic.AtomicLong; +import java.util.zip.Deflater; public class AsyncQueryForwardingServletTest extends BaseJettyTest { @@ -369,7 +371,12 @@ protected String rewriteURI(HttpServletRequest request, String scheme, String ho root.addFilter(GuiceFilter.class, "/exception/*", null); final HandlerList handlerList = new HandlerList(); - handlerList.setHandlers(new Handler[]{JettyServerInitUtils.wrapWithDefaultGzipHandler(root, 4096, -1)}); + handlerList.setHandlers( + new Handler[]{JettyServerInitUtils.wrapWithDefaultGzipHandler( + root, + ServerConfig.DEFAULT_GZIP_INFLATE_BUFFER_SIZE, + Deflater.DEFAULT_COMPRESSION)} + ); server.setHandler(handlerList); } } diff --git a/server/src/test/java/org/apache/druid/server/initialization/BaseJettyTest.java b/server/src/test/java/org/apache/druid/server/initialization/BaseJettyTest.java index 75ef8560217d..ff039e570a92 100644 --- a/server/src/test/java/org/apache/druid/server/initialization/BaseJettyTest.java +++ b/server/src/test/java/org/apache/druid/server/initialization/BaseJettyTest.java @@ -64,6 +64,7 @@ import java.io.IOException; import java.util.concurrent.ThreadLocalRandom; import java.util.concurrent.TimeUnit; +import java.util.zip.Deflater; public abstract class BaseJettyTest { @@ -145,7 +146,13 @@ public void initialize(Server server, Injector injector) root.addFilter(GuiceFilter.class, "/*", null); final HandlerList handlerList = new HandlerList(); - handlerList.setHandlers(new Handler[]{JettyServerInitUtils.wrapWithDefaultGzipHandler(root, 4096, -1)}); + handlerList.setHandlers( + new Handler[]{JettyServerInitUtils.wrapWithDefaultGzipHandler( + root, + ServerConfig.DEFAULT_GZIP_INFLATE_BUFFER_SIZE, + Deflater.DEFAULT_COMPRESSION + )} + ); server.setHandler(handlerList); }