diff --git a/native-engine/datafusion-ext-plans/src/parquet_sink_exec.rs b/native-engine/datafusion-ext-plans/src/parquet_sink_exec.rs index 652928a6e..bddf5e73d 100644 --- a/native-engine/datafusion-ext-plans/src/parquet_sink_exec.rs +++ b/native-engine/datafusion-ext-plans/src/parquet_sink_exec.rs @@ -377,6 +377,7 @@ fn parse_writer_props(prop_kvs: &[(String, String)]) -> WriterProperties { "LZO" => Compression::LZO, "BROTLI" => Compression::BROTLI(BrotliLevel::default()), "LZ4" => Compression::LZ4, + "LZ4RAW" | "LZ4_RAW" => Compression::LZ4_RAW, "ZSTD" => { let level_default = ZstdLevel::default().compression_level(); let level = prop_kvs