fix symmetric hash join cases

Signed-off-by: Ruihang Xia <[email protected]>
apache · Jun 5, 2024 · fc9a86b · fc9a86b
1 parent d13a9fe
commit fc9a86b
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 8 deletions.
diff --git a/datafusion/expr/src/interval_arithmetic.rs b/datafusion/expr/src/interval_arithmetic.rs
@@ -1021,13 +1021,20 @@ impl_OneTrait! {u8, u16, u32, u64, i8, i16, i32, i64, i128}
 
 impl OneTrait for IntervalDayTime {
     fn one() -> Self {
-        IntervalDayTime::ONE
+        IntervalDayTime {
+            days: 0,
+            milliseconds: 1,
+        }
     }
 }
 
 impl OneTrait for IntervalMonthDayNano {
     fn one() -> Self {
-        IntervalMonthDayNano::ONE
+        IntervalMonthDayNano {
+            months: 0,
+            days: 0,
+            nanoseconds: 1,
+        }
     }
 }
 

diff --git a/datafusion/physical-plan/src/joins/symmetric_hash_join.rs b/datafusion/physical-plan/src/joins/symmetric_hash_join.rs
@@ -2290,8 +2290,8 @@ mod tests {
         )]
         join_type: JoinType,
         #[values(
-        (4, 5),
-        (12, 17),
+            (4, 5),
+            (12, 17),
         )]
         cardinality: (i32, i32),
         #[values(0, 1, 2)] case_expr: usize,
@@ -2375,8 +2375,8 @@ mod tests {
         )]
         join_type: JoinType,
         #[values(
-        (4, 5),
-        (12, 17),
+            (4, 5),
+            (12, 17),
         )]
         cardinality: (i32, i32),
     ) -> Result<()> {
@@ -2452,8 +2452,8 @@ mod tests {
         )]
         join_type: JoinType,
         #[values(
-        (4, 5),
-        (12, 17),
+            (4, 5),
+            (12, 17),
         )]
         cardinality: (i32, i32),
         #[values(0, 1, 2, 3, 4, 5)] case_expr: usize,