From 00c36f83c486b840ec1c1c4393abd6636424d5a1 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Loi=CC=88c=20Alleyne?= Date: Fri, 13 Oct 2023 11:48:42 -0400 Subject: [PATCH] fix maxRec metric --- go/arrow/avro/reader.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/go/arrow/avro/reader.go b/go/arrow/avro/reader.go index 385641474d93f..4a08552cd6312 100644 --- a/go/arrow/avro/reader.go +++ b/go/arrow/avro/reader.go @@ -240,7 +240,7 @@ func (r *OCFReader) Next() bool { r.maxOCF = len(r.avroChan) } if r.maxRec < len(r.recChan) { - r.maxRec = len(r.avroChan) + r.maxRec = len(r.recChan) } select { case r.cur = <-r.recChan: