From 25c95f560b5962110660248fa7b44746478867b9 Mon Sep 17 00:00:00 2001
From: Kexiang Wang <kx.wang@hotmail.com>
Date: Tue, 6 Aug 2024 12:27:11 -0400
Subject: [PATCH] chore: add col name when type mismatch in sink

---
 src/frontend/src/handler/create_sink.rs | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/src/frontend/src/handler/create_sink.rs b/src/frontend/src/handler/create_sink.rs
index 1ca8e39adad6..fdf6a65c4437 100644
--- 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(