From c77a725f7de4f5d61b5373e2eeb8c9236b970ac5 Mon Sep 17 00:00:00 2001
From: Xiangjin <xiangjin@risingwave-labs.com>
Date: Thu, 28 Nov 2024 17:29:58 +0800
Subject: [PATCH] enrich error message

---
 e2e_test/source_inline/kafka/avro/ref.slt      | 2 +-
 src/connector/codec/src/decoder/avro/schema.rs | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/e2e_test/source_inline/kafka/avro/ref.slt b/e2e_test/source_inline/kafka/avro/ref.slt
index 8f8d12f5bdb4b..15f36cf4c0d5d 100644
--- a/e2e_test/source_inline/kafka/avro/ref.slt
+++ b/e2e_test/source_inline/kafka/avro/ref.slt
@@ -31,7 +31,7 @@ db error: ERROR: Failed to run the query
 
 Caused by these errors (recent errors listed first):
   1: connector error
-  2: circular reference detected: Node -> Node
+  2: circular reference detected in Avro schema: Node -> Node
 
 
 system ok
diff --git a/src/connector/codec/src/decoder/avro/schema.rs b/src/connector/codec/src/decoder/avro/schema.rs
index 5f2127b40ace8..d226098f63d47 100644
--- a/src/connector/codec/src/decoder/avro/schema.rs
+++ b/src/connector/codec/src/decoder/avro/schema.rs
@@ -224,7 +224,7 @@ fn avro_type_mapping(
             let unique_name = name.fullname(None);
             if ancestor_records.contains(&unique_name) {
                 bail!(
-                    "circular reference detected: {} -> {}",
+                    "circular reference detected in Avro schema: {} -> {}",
                     ancestor_records.join(" -> "),
                     unique_name
                 );