diff --git a/pkg/archive/parquet/nodestate_writer.go b/pkg/archive/parquet/nodestate_writer.go
index 053417d6..e8487556 100644
--- a/pkg/archive/parquet/nodestate_writer.go
+++ b/pkg/archive/parquet/nodestate_writer.go
@@ -83,7 +83,7 @@ func writeNodeStateParquetBytes(rows []ParquetNodeStateRow) ([]byte, error) {
 	var buf bytes.Buffer
 
 	writer := pq.NewGenericWriter[ParquetNodeStateRow](&buf,
-		pq.Compression(&pq.Snappy),
+		pq.Compression(&pq.Zstd),
 	)
 
 	if _, err := writer.Write(rows); err != nil {
diff --git a/pkg/archive/parquet/writer.go b/pkg/archive/parquet/writer.go
index 2669a9c8..e5dc0d9d 100644
--- a/pkg/archive/parquet/writer.go
+++ b/pkg/archive/parquet/writer.go
@@ -87,7 +87,7 @@ func writeParquetBytes(rows []ParquetJobRow) ([]byte, error) {
 	var buf bytes.Buffer
 
 	writer := pq.NewGenericWriter[ParquetJobRow](&buf,
-		pq.Compression(&pq.Snappy),
+		pq.Compression(&pq.Zstd),
 	)
 
 	if _, err := writer.Write(rows); err != nil {