diff --git a/go/common/arrow_util/arrow_util.go b/go/common/arrow_util/arrow_util.go index 6e89058e..ee21b0ca 100644 --- a/go/common/arrow_util/arrow_util.go +++ b/go/common/arrow_util/arrow_util.go @@ -48,7 +48,7 @@ func MakeArrowRecordReader(reader *pqarrow.FileReader, opts *options.ReadOptions columnIndices = append(columnIndices, metadata.Schema.ColumnIndexByName(f.GetColumnName())) } - for i := 0; i < int(metadata.NumRows); i++ { + for i := 0; i < len(metadata.RowGroups); i++ { rg := metadata.RowGroup(i) var canIgnored bool for _, filter := range opts.Filters {