Skip to content

Commit c8e9403

Browse files
ban compression
Signed-off-by: Little-Wallace <bupt2013211450@gmail.com>
1 parent a632aff commit c8e9403

1 file changed

Lines changed: 1 addition & 6 deletions

File tree

src/log_batch.rs

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -591,12 +591,7 @@ where
591591
item.encode_to::<W>(&mut vec).unwrap();
592592
}
593593

594-
let compression_type = if vec.len() > COMPRESSION_SIZE {
595-
vec = lz4::encode_block(&vec[HEADER_LEN..], HEADER_LEN, 4);
596-
CompressionType::Lz4
597-
} else {
598-
CompressionType::None
599-
};
594+
let compression_type = CompressionType::None;
600595

601596
let checksum = crc32(&vec[8..]);
602597
vec.encode_u32_le(checksum).unwrap();

0 commit comments

Comments
 (0)