diff --git a/pageserver/src/tenant/blob_io.rs b/pageserver/src/tenant/blob_io.rs index 0705182d5db29..184a998521ce8 100644 --- a/pageserver/src/tenant/blob_io.rs +++ b/pageserver/src/tenant/blob_io.rs @@ -123,7 +123,7 @@ impl<'a> BlockCursor<'a> { } if let Some(dstbuf) = compression { - if compression_bits == BYTE_ZSTD { + if compression_bits == BYTE_ZSTD + 1{ let mut decoder = async_compression::tokio::write::ZstdDecoder::new(dstbuf); decoder.write_all(buf_to_write).await?; decoder.flush().await?;