ошибку
2022.09.23 14:34:19.055239 [ 2083027 ] {} <Error> void DB::StorageKafka::threadFunc(size_t): Code: 122. DB::Exception: Data in Object has ambiguous paths: 'amount.amount' and 'amount': while converting source column event_parameters to destination column event_parameters: while executing 'FUNCTION _CAST(event_parameters :: 4, Object('json') :: 22) -> _CAST(event_parameters, Object('json')) Object('json') : 21': while pushing to view default.consumer (a7c22a36-21ee-42d9-8f87-0fb825b7ba58). (INCOMPATIBLE_COLUMNS), Stack trace (when copying this message, always include the lines below)
значение event_parameters примерно такое '{"amount": {"amount": 123, "foo": "bar"}'
может у кого-то есть идеи как это можно исправить?
дроп/создание таблицы kafka engine не помогло.
вообще странно, что КХ стал падать на этом. на чистой базе он прожевывает такой формат данных.
причем предыдущие сообщения где нет вложенного жсона, вполне нормально съедал. тип поля event_parameters - Object('json') версия КХ - (version 22.5.1.2079 (official build))
Обсуждают сегодня