From 09db7873c0ed36975ec434dd75e6e1172baf19ad Mon Sep 17 00:00:00 2001
From: metesynnada <100111937+metesynnada@users.noreply.github.com>
Date: Tue, 30 Jan 2024 09:37:11 +0300
Subject: [PATCH] Alter a test to support new functionality

---
 .../physical-plan/src/joins/symmetric_hash_join.rs     | 10 ++++++++--
 1 file changed, 8 insertions(+), 2 deletions(-)

diff --git a/datafusion/physical-plan/src/joins/symmetric_hash_join.rs b/datafusion/physical-plan/src/joins/symmetric_hash_join.rs
index 3f907930d69e..42c7029edcc1 100644
--- a/datafusion/physical-plan/src/joins/symmetric_hash_join.rs
+++ b/datafusion/physical-plan/src/joins/symmetric_hash_join.rs
@@ -1330,8 +1330,9 @@ mod tests {
     use arrow::datatypes::{DataType, Field, IntervalUnit, Schema, TimeUnit};
     use datafusion_execution::config::SessionConfig;
     use datafusion_expr::Operator;
-    use datafusion_physical_expr::expressions::{binary, col, Column};
+    use datafusion_physical_expr::expressions::{binary, col, lit, Column};
 
+    use datafusion_common::ScalarValue;
     use once_cell::sync::Lazy;
     use rstest::*;
 
@@ -1451,7 +1452,12 @@ mod tests {
         )?;
 
         let on = vec![(
-            Arc::new(Column::new_with_schema("lc1", left_schema)?) as _,
+            binary(
+                col("lc1", left_schema)?,
+                Operator::Plus,
+                lit(ScalarValue::Int32(Some(1))),
+                left_schema,
+            )?,
             Arc::new(Column::new_with_schema("rc1", right_schema)?) as _,
         )];