diff --git a/arrow/cdata/exports.go b/arrow/cdata/exports.go index 15fc36a2..84bb9114 100644 --- a/arrow/cdata/exports.go +++ b/arrow/cdata/exports.go @@ -373,6 +373,7 @@ func exportAsyncProducer(schema *arrow.Schema, stream <-chan RecordMessage, hand return err case req := <-reqChan: pending += req + default: } if pending > 0 {