diff --git a/rust/cubestore/cubestore/src/table/parquet.rs b/rust/cubestore/cubestore/src/table/parquet.rs index ab6f51294dae6..d88b0b9708bde 100644 --- a/rust/cubestore/cubestore/src/table/parquet.rs +++ b/rust/cubestore/cubestore/src/table/parquet.rs @@ -137,7 +137,8 @@ impl ParquetTableStore { table, WriterProperties::builder() .set_max_row_group_size(self.row_group_size) - .set_writer_version(WriterVersion::PARQUET_2_0), + .set_writer_version(WriterVersion::PARQUET_2_0) + .set_compression(datafusion::parquet::basic::Compression::ZSTD), ) .await .map_err(CubeError::from)