chore: add col name when type mismatch in sink

risingwavelabs · Aug 6, 2024 · 25c95f5 · 25c95f5
1 parent 891f7b3
commit 25c95f5
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/src/frontend/src/handler/create_sink.rs b/src/frontend/src/handler/create_sink.rs
@@ -738,9 +738,10 @@ fn derive_sink_to_table_expr(
 
     if target_type != input_type {
         bail!(
-            "column type mismatch: {:?} vs {:?}",
+            "column type mismatch: {:?} vs {:?}, column name: {:?}",
             target_type,
-            input_type
+            input_type,
+            sink_schema.fields()[idx].name
         );
     } else {
         Ok(ExprImpl::InputRef(Box::new(InputRef::new(