chore: Add datatype info to error message

viirya · Apr 30, 2024 · 97302dc · 97302dc
1 parent dd56837
commit 97302dc
Showing 1 changed file with 10 additions and 8 deletions.
diff --git a/datafusion/physical-plan/src/joins/sort_merge_join.rs b/datafusion/physical-plan/src/joins/sort_merge_join.rs
@@ -1517,10 +1517,11 @@ fn compare_join_arrays(
             },
             DataType::Date32 => compare_value!(Date32Array),
             DataType::Date64 => compare_value!(Date64Array),
-            _ => {
-                return not_impl_err!(
-                    "Unsupported data type in sort merge join comparator"
-                );
+            dt => {
+                return not_impl_err!("{}", format!(
+                    "Unsupported data type in sort merge join comparator: {}",
+                    dt
+                ));
             }
         }
         if !res.is_eq() {
@@ -1583,10 +1584,11 @@ fn is_join_arrays_equal(
             },
             DataType::Date32 => compare_value!(Date32Array),
             DataType::Date64 => compare_value!(Date64Array),
-            _ => {
-                return not_impl_err!(
-                    "Unsupported data type in sort merge join comparator"
-                );
+            dt => {
+                return not_impl_err!("{}", format!(
+                    "Unsupported data type in sort merge join comparator: {}",
+                    dt
+                ));
             }
         }
         if !is_equal {