fix maxRec metric

apache · Oct 13, 2023 · 060b375 · 060b375
1 parent 138dd73
commit 060b375
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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: