diff --git a/go/parquet/internal/encoding/delta_bit_packing.go b/go/parquet/internal/encoding/delta_bit_packing.go index becacef555077..ac91953a7f903 100644 --- a/go/parquet/internal/encoding/delta_bit_packing.go +++ b/go/parquet/internal/encoding/delta_bit_packing.go @@ -153,7 +153,7 @@ func (d *deltaBitPackDecoder[T]) unpackNextMini() error { // Decode retrieves min(remaining values, len(out)) values from the data and returns the number // of values actually decoded and any errors encountered. func (d *deltaBitPackDecoder[T]) Decode(out []T) (int, error) { - max := shared_utils.Min(len(out), int(d.totalValues)) + max := shared_utils.Min(len(out), int(d.nvals)) if max == 0 { return 0, nil }