fixed nl join filter expression in tests

korowa · Apr 22, 2024 · 45f170d · 45f170d
1 parent 06c9f03
commit 45f170d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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,