From 757be60b22cdcf5e0f31acd5cf658cdcd7c745ba Mon Sep 17 00:00:00 2001 From: Jan Eitzinger Date: Wed, 18 Feb 2026 07:55:28 +0100 Subject: [PATCH] Switch to zstd compression for parquet writers --- pkg/archive/parquet/nodestate_writer.go | 2 +- pkg/archive/parquet/writer.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) 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 {