rdettai commented on issue #612:
URL:
https://github.com/apache/arrow-datafusion/issues/612#issuecomment-867008993
Locally, I have a test that has nothing to do with this change that is
failing:
- physical_plan::repartition::tests::repartition_with_dropping_output_stream
```
----
physical_plan::repartition::tests::repartition_with_dropping_output_stream
stdout ----
Running case RoundRobinBatch(2)
BarrierExec::wait waiting on barrier
Partition 0 waiting on barrier
Partition 1 waiting on barrier
Partition 1 sending batch
Partition 1 sending batch
Partition 0 sending batch
Partition 0 sending batch
BarrierExec::wait done waiting
Running case Hash([Column { name: "my_awesome_field", index: 0 }], 2)
BarrierExec::wait waiting on barrier
Partition 0 waiting on barrier
Partition 1 waiting on barrier
Partition 1 sending batch
Partition 1 sending batch
Partition 0 sending batch
Partition 0 sending batch
BarrierExec::wait done waiting
thread
'physical_plan::repartition::tests::repartition_with_dropping_output_stream'
panicked at 'assertion failed: `(left == right)`
left: `["+------------------+", "| my_awesome_field |",
"+------------------+", "| frob |", "+------------------+"]`,
right: `["+------------------+", "| my_awesome_field |",
"+------------------+", "| foo |", "| frob |", "| gar
|", "| gaz |", "| goo |", "| grob
|", "+------------------+"]`:
expected:
[
"+------------------+",
"| my_awesome_field |",
"+------------------+",
"| frob |",
"+------------------+",
]
actual:
[
"+------------------+",
"| my_awesome_field |",
"+------------------+",
"| foo |",
"| frob |",
"| gar |",
"| gaz |",
"| goo |",
"| grob |",
"+------------------+",
]
', datafusion/src/physical_plan/repartition.rs:799:13
```
Any idea why that might be @alamb ?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
