You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
According to the code, when the outer table returns None for the first time, the NestedLoopJoinStream may return Some(RecordBatch) to produce the result for the unmatched rows. Therefore, the NestedLoopJoinStream is not exhausted and will be polled again. However, the next poll will also poll the outer_table, when the outer_table does not support the FusedStream, it may panic.
To fix the bug, we could require the execute method returns a FusedStream or add a wrapper for the outer_table
To Reproduce
No response
Expected behavior
No response
Additional context
No response
The text was updated successfully, but these errors were encountered:
Describe the bug
According to the code, when the outer table returns
None
for the first time, theNestedLoopJoinStream
may returnSome(RecordBatch)
to produce the result for the unmatched rows. Therefore, theNestedLoopJoinStream
is not exhausted and will be polled again. However, the next poll will also poll the outer_table, when the outer_table does not support the FusedStream, it may panic.To fix the bug, we could require the execute method returns a
FusedStream
or add a wrapper for the outer_tableTo Reproduce
No response
Expected behavior
No response
Additional context
No response
The text was updated successfully, but these errors were encountered: