Skip to content

Commit

Permalink
enrich error message
Browse files Browse the repository at this point in the history
  • Loading branch information
xiangjinwu committed Nov 28, 2024
1 parent 9e35db2 commit c77a725
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion e2e_test/source_inline/kafka/avro/ref.slt
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
2 changes: 1 addition & 1 deletion src/connector/codec/src/decoder/avro/schema.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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
);
Expand Down

0 comments on commit c77a725

Please sign in to comment.