troubleshooting
How to resolve the unsupported type in Avro error when streaming data from Confluent Kafka to RisingWave with numeric columns?
I'm getting the error ERROR: QueryError: internal error: unsupported type in Avro: Ref { name: Name { name: "VariableScaleDecimal", namespace: Some("io.debezium.data") } }
when trying to create table on RisingWave due to numeric columns. How can I resolve this issue?
Da
Dat Nguyen
Asked on Jun 12, 2023
- The unsupported type in Avro error occurs when there is a numeric column with variable scale (defined with the
numeric
) in the Avro schema. - To resolve this issue, you can temporarily work around it by changing the data type in the source database from
numeric
tonumeric(x, y)
wherex
andy
are the precision and scale of the numeric column.
Example:
-- Before
CREATE TABLE my_table (
my_numeric_column NUMERIC
);
-- After
CREATE TABLE my_table (
my_numeric_column NUMERIC(x, y)
);
- This workaround should allow you to stream data from Confluent Kafka to RisingWave without encountering the unsupported type error.
Jun 15, 2023Edited by