184 похожих чатов

Всем привет! Есть kafka_engine табличка с полями `Status`

nullable(Int16),
`Cause` nullable(Int16)
kafka_format = 'JSONEachRow'
В кафке
,"Status":"-1","Cause":"",

Но при выборке с кафка таблички всё равно вижу, что происходит подмена Cause на 0. Не учёл какую-то системную настройку?
SELECT
date_time,
Status,
Cause
FROM Test_kafka
ORDER BY date_time DESC
LIMIT 10

Query id: d165ea9c-db66-402c-9eb2-5c3e00ddc5cd

┌───────────date_time─┬─Status─┬─Cause─┐
│ 2021-10-29 14:43:54 │ -1 │ 0 │

3 ответов

11 просмотров

попробуйте Nullable с большой буквы

--input_format_null_as_default arg For text input formats initialize null fields with default values if data type of this field is not nullable

Andrei-Dovgalyuk Автор вопроса
Denny [Altinity]
--input_format_null_as_default arg ...

Но у меня же как раз указан data type is nullable, разве нет? CREATE TABLE statistics.test_null_kafka ( `Status` Nullable(Int16), `Cause` Nullable(Int16) ) ENGINE = Kafka SETTINGS kafka_broker_list = '172.26.17.61:9092', kafka_topic_list = 'test_null_kafka', kafka_group_name = 'clickhouse_prod_71', kafka_format = 'JSONEachRow'; [root@Mon-01 kafka]# ./kafka-tldl.sh read test_null_kafka {"Status":"-1","Cause":""} localhost :) select * from test_null_kafka; SELECT * FROM test_null_kafka Query id: eece2c04-3b39-4405-a71b-a316c7561595 ┌─Status─┬─Cause─┐ │ -1 │ 0 │ └────────┴───────┘

Похожие вопросы

Обсуждают сегодня

Типа вызывать GetParent и проверять на соответствие GetModuleHandle?
The Bird of Hermes
67
Всем привет! Кто нибудь парсил в ручную JSON без библиотек и фреймворков? Есть может ссылки на оптимальный алгоритмы работы с текстом и примеры таких парсеров?
Lem
27
Do any of you guys have interesting projects one could join? I'm a Middle Full-Stack developer (JS/TS, React & Node)
Lev Shapiro
40
Есть сайт. Там была древняя версия эво. Стоял плагин, который каждый коммент в Jot делал отдельной страницей. После обновления все слетело, теперь старница открывается отдельн...
Artem
1
$res = json_decode($наша строка из респонса); $res1 = array_map(fn($o) => $o->name, $res->breadcrumbs[0]->entities); Как такое будет на Хаскеле?.. В начале весь джейсон, в ко...
Хаскель Моисеевич Гопник
27
Добрый день. А shovel'ы можно как-то сконфигурировать в definitions.json? Пробовал что-то вроде: { "users": [ { "name": "agent", "password_hash": "RBCbTzQd...
Aleksey
1
Вопрос по диагностике ошибок (я знаю в чем, в данном конкретном примере, я знаю, как исправить, пример модельный, понятно, что в реальности бывает намного запутаннее). module...
ⰄⰎⰋⰐⰐⰑⰛⰤⰧⰧⰩⰄ ⰊⰑⰁⰓⰡⰛⰦⰕⰫ
11
В чем сила брат, в NASM или FASM?
Isaac Kleiner
18
А чем вам питонисты не угодили?😂
.
79
Есть какой-нибудь для Delphi/FPC T*Compression(Decompression)Stream на базе LZ4/Zstd/любой другой быстрый(и хорошо сжимающий) алгоритм А ещё лучше в pure pascal А ещё лучше од...
notme
52
Карта сайта