diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/io/Compression.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/io/Compression.java
index d9e7757547f5..976245f78544 100644
--- a/sdks/java/core/src/main/java/org/apache/beam/sdk/io/Compression.java
+++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/io/Compression.java
@@ -99,7 +99,9 @@ public ReadableByteChannel readDecompressed(ReadableByteChannel channel) throws
 
     @Override
     public WritableByteChannel writeCompressed(WritableByteChannel channel) throws IOException {
-      return Channels.newChannel(new GZIPOutputStream(Channels.newOutputStream(channel), true));
+      // Increase the default deflate output stream buffer size from 512 to 4096 for performance.
+      return Channels.newChannel(
+          new GZIPOutputStream(Channels.newOutputStream(channel), 4096, true));
     }
   },