Я бы посмотрел исходный код в таком случае

Скажите, как должна работать репликация с Kafka engine и consumer MV, если вот мы используем ReplicatedMergeTree, то такая таблица реплицируется на серверах,
а как обстоит дело с Kafka engine и consumer MV? Они получается существуют только в одном из серверов, и никакой речи про реплики в их отношении не идет?

kafka engine сама по себе ничего не хранит, что ей реплицировать?

Добрый день! Может уже кто сталкивался - из питона грузим данные в clickhouse (немного, 190 тысяч строк в пакете)

2020.06.23 15:11:38.612603 [ 559938 ] {f42a45fb-b4ba-416b-bcce-0ae5d59c5d40} <Error> executeQuery: Code: 206, e.displayText() = DB::Exception: No alias for subquery or tabl
e function in JOIN (set joined_subquery_requires_alias=0 to disable restriction). (version 20.3.11.97) (from [::ffff:10.88.5.160]:50570) (in query: INSERT INTO Table_bu
ffer (uuid, pkghash) VALUES), Stack trace (when copying this message, always include the lines below):

<Empty trace>

Не пойму, каких ему алиасов в INSERT не хватает ?

мы сделали так: kafka engine -> MV -> Distributed MergeTree -> target ReplicatedMergeTree на каждой ноде кластера

Отключение  joined_subquery_requires_alias для запроса NSERT INTO Table_buffer (uuid, pkghash) VALUES помогает, но хотелось бы разобраться в чём проблема

MV висит на этой таблице?

вполне может быть. надо поискать

спасибо. я понял куда покопать

Вообще суть в том, что раньше было можно, но потом сделали более строгое поведение с джойнами и впилили настройку для возврата к старому поведению

да, все JOIN уже исправлены. Вот про MV я может быть забыл

Точно. Нашёл MV с этой табличкой. Спасибо ещё раз.

я вот думаю пока достаточно без Distributed для начала
kafka engine -> MV -> target ReplicatedMergeTree

Вообще идея через дистрибьютед так себе

лучше напрямую в шарды, тем более кафка это позволяет

https://github.com/Flamefork/dbmate/tree/clickhouse
(пока форк)
но мы только начали

Добрый день, коллеги
Можно ли функцию словаря dictGet() применить к массиву идентификторов?

arrayMap?

arrayMap(p -> dictGet(…, p), […])

Мы юзаем infi.clickhouse_orm и модели и миграции + дописали туда вьюхи, материализованные представления и AggregatingMergeTree движок с AggregateFunctions. 30+ миграций - полёт нормальный.