You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Description
The ksqlDB stream doesn't return any results when querying MAP data that was created using 'INSERT INTO'. This only affects JSON_SR schemas on CCloud.
To Reproduce
CREATE STREAM MAP_TEST (ID INT KEY, DATA STRUCT<VAL MAP<STRING, STRING>>)
WITH (kafka_topic='MAP_TEST', partitions=1, value_format='json_sr');
INSERT INTO MAP_TEST (ID, DATA) VALUES (1, STRUCT(VAL := MAP('a' := '1', 'b' := '2')));
SELECT * FROM MAP_TEST EMIT CHANGES;
Expected behavior
A new row is emitted showing the data that was inserted.
Actual Behaviour
No data comes through and the processing logs show the following:
"ERRORMESSAGE": "Failed to deserialize value from topic: MAP_TEST. Can't convert type. sourceType: ArrayNode, requiredType: MAP<VARCHAR, VARCHAR>, path: $.DATA.VAL"
Additional context
The INSERT INTO statement registers a schema (see below). This schema shows an array of objects as well as 'connect.index' attributes. It seems that the consumer used by the SELECT statement doesn't know how to deserialise to the map format.
Description
The ksqlDB stream doesn't return any results when querying MAP data that was created using 'INSERT INTO'. This only affects JSON_SR schemas on CCloud.
To Reproduce
Expected behavior
A new row is emitted showing the data that was inserted.
Actual Behaviour
No data comes through and the processing logs show the following:
Additional context
The INSERT INTO statement registers a schema (see below). This schema shows an array of objects as well as 'connect.index' attributes. It seems that the consumer used by the SELECT statement doesn't know how to deserialise to the map format.
The text was updated successfully, but these errors were encountered: