diff --git a/native/core/src/execution/shuffle/shuffle_writer.rs b/native/core/src/execution/shuffle/shuffle_writer.rs index 38fd4bd18..8ff8b9693 100644 --- a/native/core/src/execution/shuffle/shuffle_writer.rs +++ b/native/core/src/execution/shuffle/shuffle_writer.rs @@ -1619,7 +1619,7 @@ pub fn write_ipc_compressed( // fill ipc length let end_pos = output.stream_position()?; - let compressed_length = end_pos - start_pos - 16; + let compressed_length = end_pos - start_pos - 8; // fill ipc length output.seek(SeekFrom::Start(start_pos))?;