diff --git a/rust/parquet/src/encodings/decoding.rs b/rust/parquet/src/encodings/decoding.rs index f1e98cc606d..02f0a1c9c59 100644 --- a/rust/parquet/src/encodings/decoding.rs +++ b/rust/parquet/src/encodings/decoding.rs @@ -301,6 +301,7 @@ impl Decoder for RleValueDecoder { // We still need to remove prefix of i32 from the stream. const I32_SIZE: usize = mem::size_of::(); let data_size = read_num_bytes!(i32, I32_SIZE, data.as_ref()) as usize; + self.decoder = RleDecoder::new(1); self.decoder.set_data(data.range(I32_SIZE, data_size)); self.values_left = num_values; Ok(())