File tree Expand file tree Collapse file tree 1 file changed +5
-1
lines changed
Expand file tree Collapse file tree 1 file changed +5
-1
lines changed Original file line number Diff line number Diff line change @@ -533,7 +533,7 @@ namespace {
533533struct ExportedArrayPrivateData : PoolAllocationMixin<ExportedArrayPrivateData> {
534534 // The buffers are owned by the ArrayData member
535535 SmallVector<const void *, 3 > buffers_;
536- struct ArrowArray dictionary_ {};
536+ struct ArrowArray dictionary_{};
537537 SmallVector<struct ArrowArray , 1 > children_;
538538 SmallVector<struct ArrowArray *, 4 > child_pointers_;
539539
@@ -2629,6 +2629,10 @@ class AsyncRecordBatchIterator {
26292629
26302630 private_data->state_ ->schema_ = maybe_schema.MoveValueUnsafe ();
26312631 private_data->fut_iterator_ .MarkFinished (private_data->state_ );
2632+ if (self->producer == nullptr ) {
2633+ private_data->fut_iterator_ .MarkFinished (Status::Invalid (" Missing producer" ));
2634+ return EINVAL;
2635+ }
26322636 self->producer ->request (self->producer ,
26332637 static_cast <int64_t >(private_data->state_ ->queue_size_ ));
26342638 return 0 ;
You can’t perform that action at this time.
0 commit comments