From 7771636036062d8236db6ef22e583fbfe99daf74 Mon Sep 17 00:00:00 2001 From: JacobSMoller Date: Fri, 25 Jul 2025 10:48:20 +0200 Subject: [PATCH] BUG: Snappy checksum check --- pyiceberg/avro/codecs/snappy_codec.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pyiceberg/avro/codecs/snappy_codec.py b/pyiceberg/avro/codecs/snappy_codec.py index 2da8ed8f72..2ea7229772 100644 --- a/pyiceberg/avro/codecs/snappy_codec.py +++ b/pyiceberg/avro/codecs/snappy_codec.py @@ -51,9 +51,9 @@ def compress(data: bytes) -> tuple[bytes, int]: @staticmethod def decompress(data: bytes) -> bytes: # Compressed data includes a 4-byte CRC32 checksum - data = data[0:-4] + checksum = data[-4:] # store checksum before truncating data + data = data[0:-4] # remove checksum from the data uncompressed = snappy.decompress(data) - checksum = data[-4:] SnappyCodec._check_crc32(uncompressed, checksum) return uncompressed