diff --git a/core/trino-main/src/main/java/io/trino/server/protocol/spooling/encoding/Lz4QueryDataEncoder.java b/core/trino-main/src/main/java/io/trino/server/protocol/spooling/encoding/Lz4QueryDataEncoder.java
index 07488eba52e5..287b29c84cc9 100644
--- a/core/trino-main/src/main/java/io/trino/server/protocol/spooling/encoding/Lz4QueryDataEncoder.java
+++ b/core/trino-main/src/main/java/io/trino/server/protocol/spooling/encoding/Lz4QueryDataEncoder.java
@@ -22,7 +22,7 @@
 public class Lz4QueryDataEncoder
         extends CompressedQueryDataEncoder
 {
-    private static final int COMPRESSION_THRESHOLD = 2048;
+    private static final int COMPRESSION_THRESHOLD = 8192;
 
     public Lz4QueryDataEncoder(QueryDataEncoder delegate)
     {
diff --git a/core/trino-main/src/main/java/io/trino/server/protocol/spooling/encoding/ZstdQueryDataEncoder.java b/core/trino-main/src/main/java/io/trino/server/protocol/spooling/encoding/ZstdQueryDataEncoder.java
index e916916a07bc..d4f91cc9e2c5 100644
--- a/core/trino-main/src/main/java/io/trino/server/protocol/spooling/encoding/ZstdQueryDataEncoder.java
+++ b/core/trino-main/src/main/java/io/trino/server/protocol/spooling/encoding/ZstdQueryDataEncoder.java
@@ -22,7 +22,7 @@
 public class ZstdQueryDataEncoder
         extends CompressedQueryDataEncoder
 {
-    private static final int COMPRESSION_THRESHOLD = 2048;
+    private static final int COMPRESSION_THRESHOLD = 8192;
 
     public ZstdQueryDataEncoder(QueryDataEncoder delegate)
     {