diff --git a/src/mito2/src/memtable/bulk/part.rs b/src/mito2/src/memtable/bulk/part.rs index f2402406a4..a3718b66a3 100644 --- a/src/mito2/src/memtable/bulk/part.rs +++ b/src/mito2/src/memtable/bulk/part.rs @@ -45,6 +45,7 @@ use mito_codec::row_converter::{ DensePrimaryKeyCodec, PrimaryKeyCodec, PrimaryKeyCodecExt, build_primary_key_codec, }; use parquet::arrow::ArrowWriter; +use parquet::basic::{Compression, ZstdLevel}; use parquet::data_type::AsBytes; use parquet::file::metadata::ParquetMetaData; use parquet::file::properties::WriterProperties; @@ -635,6 +636,7 @@ impl BulkPartEncoder { .set_key_value_metadata(Some(vec![key_value_meta])) .set_write_batch_size(row_group_size) .set_max_row_group_size(row_group_size) + .set_compression(Compression::ZSTD(ZstdLevel::default())) .set_column_index_truncate_length(None) .set_statistics_truncate_length(None) .build(),