Skip to content

[Rust][DataFusion] CoalesceBatchesStream doesn't honor Stream interface #27636

Description

@asfimport

The Stream interface has a contract which states that you cannot poll anymore once you have received None. See futures::prelude::Stream - Rust (docs.rs)

This is not being honored and it causes a hand if you CoallesceBatchesExec after a RepartitionExec

Reporter: Ximo Guanter

PRs and other links:

Note: This issue was originally created as ARROW-11784. Please see the migration documentation for further details.

Metadata

Metadata

Assignees

No one assigned

    Type

    No type
    No fields configured for issues without a type.

    Projects

    No projects

    Milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions