diff --git a/core/trino-main/src/main/java/io/trino/FeaturesConfig.java b/core/trino-main/src/main/java/io/trino/FeaturesConfig.java index 4e32436a250e..ca3dba9d02ef 100644 --- a/core/trino-main/src/main/java/io/trino/FeaturesConfig.java +++ b/core/trino-main/src/main/java/io/trino/FeaturesConfig.java @@ -93,7 +93,7 @@ public class FeaturesConfig /** * default value is overwritten for fault tolerant execution in {@link #applyFaultTolerantExecutionDefaults()}} */ - private CompressionCodec exchangeCompressionCodec = NONE; + private CompressionCodec exchangeCompressionCodec = LZ4; private boolean pagesIndexEagerCompactionEnabled; private boolean omitDateTimeTypePrecision; private int maxRecursionDepth = 10; diff --git a/core/trino-main/src/test/java/io/trino/sql/analyzer/TestFeaturesConfig.java b/core/trino-main/src/test/java/io/trino/sql/analyzer/TestFeaturesConfig.java index b385ed3fb411..1666e6a7a643 100644 --- a/core/trino-main/src/test/java/io/trino/sql/analyzer/TestFeaturesConfig.java +++ b/core/trino-main/src/test/java/io/trino/sql/analyzer/TestFeaturesConfig.java @@ -28,6 +28,7 @@ import static io.airlift.units.DataSize.Unit.GIGABYTE; import static io.airlift.units.DataSize.Unit.KILOBYTE; import static io.airlift.units.DataSize.Unit.MEGABYTE; +import static io.trino.execution.buffer.CompressionCodec.LZ4; import static io.trino.execution.buffer.CompressionCodec.NONE; import static io.trino.execution.buffer.CompressionCodec.ZSTD; import static io.trino.sql.analyzer.RegexLibrary.JONI; @@ -53,7 +54,7 @@ public void testDefaults() .setSpillMaxUsedSpaceThreshold(0.9) .setMemoryRevokingThreshold(0.9) .setMemoryRevokingTarget(0.5) - .setExchangeCompressionCodec(NONE) + .setExchangeCompressionCodec(LZ4) .setExchangeDataIntegrityVerification(DataIntegrityVerification.ABORT) .setPagesIndexEagerCompactionEnabled(false) .setFilterAndProjectMinOutputPageSize(DataSize.of(500, KILOBYTE))