diff --git a/datafusion/core/src/physical_optimizer/join_selection.rs b/datafusion/core/src/physical_optimizer/join_selection.rs index 9d6c576f8904..95bfa3a18fc3 100644 --- a/datafusion/core/src/physical_optimizer/join_selection.rs +++ b/datafusion/core/src/physical_optimizer/join_selection.rs @@ -848,7 +848,7 @@ mod tests_statistical { let expression = Arc::new(BinaryExpr::new( Arc::new(Column::new_with_schema("big_col", &intermediate_schema).unwrap()), Operator::Gt, - Arc::new(Column::new_with_schema("big_col", &intermediate_schema).unwrap()), + Arc::new(Column::new_with_schema("small_col", &intermediate_schema).unwrap()), )) as _; Some(JoinFilter::new( expression,