Skip to content

Commit 34cc054

Browse files
alamberratic-pattern
authored andcommitted
(New) Test + workaround for SanityCheck plan
1 parent 33d1a65 commit 34cc054

File tree

1 file changed

+10
-0
lines changed

1 file changed

+10
-0
lines changed

datafusion/physical-optimizer/src/sanity_checker.rs

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -32,6 +32,8 @@ use datafusion_common::tree_node::{Transformed, TransformedResult, TreeNode};
3232
use datafusion_physical_expr::intervals::utils::{check_support, is_datatype_supported};
3333
use datafusion_physical_plan::execution_plan::{Boundedness, EmissionType};
3434
use datafusion_physical_plan::joins::SymmetricHashJoinExec;
35+
use datafusion_physical_plan::sorts::sort::SortExec;
36+
use datafusion_physical_plan::union::UnionExec;
3537
use datafusion_physical_plan::{get_plan_string, ExecutionPlanProperties};
3638

3739
use crate::PhysicalOptimizerRule;
@@ -135,6 +137,14 @@ pub fn check_plan_sanity(
135137
plan.required_input_ordering(),
136138
plan.required_input_distribution(),
137139
) {
140+
// TEMP HACK WORKAROUND https://github.com/apache/datafusion/issues/11492
141+
if child.as_any().downcast_ref::<UnionExec>().is_some() {
142+
continue;
143+
}
144+
if child.as_any().downcast_ref::<SortExec>().is_some() {
145+
continue;
146+
}
147+
138148
let child_eq_props = child.equivalence_properties();
139149
if let Some(sort_req) = sort_req {
140150
let sort_req = sort_req.into_single();

0 commit comments

Comments
 (0)