We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 4d24c5b commit cf04fd7Copy full SHA for cf04fd7
datafusion/core/tests/physical_optimizer/enforce_distribution.rs
@@ -3212,6 +3212,7 @@ async fn apply_enforce_distribution_multiple_times() -> Result<()> {
3212
Arc::new(ProjectionPushdown::new()),
3213
Arc::new(CoalesceBatches::new()),
3214
Arc::new(EnforceDistribution::new()), // -- Add enforce distribution rule again
3215
+ // The second `EnforceDistribution` should be run before removing `OutputRequirements` to reproduce the bug.
3216
Arc::new(OutputRequirements::new_remove_mode()),
3217
3218
Arc::new(LimitPushdown::new()),
0 commit comments