А как работает получение списка партиций `SELECT * FROM system.parts WHERE

Question

А как работает получение списка партиций `SELECT * FROM system.parts WHERE

active and database = '<db>'
`,

когда есть таблицы distributed? (и кластер) Сейчас время от времени возвращается результат

#backend #clickhouse #database #devops #programming #russian

0

06.07.2021

10 ответов

32 просмотра

Kuzma Leshakov Автор вопроса

Denny [Altinity]
никак. system.parts ничего не знает про кластер.

Т е при применении кластеров нельзя получить список партиций таким способом? Или это еще Distributed не закончил процесс раскидывания данных? Есть таблица MergeTree, есть Distributed Так после этого запроса на партиции ответ приходит через раз create table db.table_local on cluster clickhouse1 ( video_id String, publication_ts DateTime, version Date ) Engine = MergeTree() partition by version order by tuple() SETTINGS index_granularity = 8192 create table db.table on cluster clickhouse1 ( video_id String, publication_ts DateTime, version Date ) Engine = Distributed(clickhouse1, db, table_local, rand()) db тоже создана ON CLUSTER

0

06.07.2021

Denny [Altinity]

Kuzma Leshakov
Т е при применении кластеров нельзя получить списо...

каша, какая каша. Если вы используете инсерт в Distributed и вам нужна гарантия вставки в реальные таблицы, то просто установите insert_distributed_sync = 1 --insert_distributed_sync arg If setting is enabled, insert query into distributed waits until data will be sent to all nodes in cluster. если вы хотите увидеть сколько еще не раскидано, испольуйте system.distribution_queue если вы хотите сделать запрос ко всем нодам, используйте from clusterAllRelicas

0

06.07.2021

Denny [Altinity]

Kuzma Leshakov
Т е при применении кластеров нельзя получить списо...

так у вас нет репликации, вы что пытаетесь сделать?

0

06.07.2021

Kuzma Leshakov Автор вопроса

Denny [Altinity]
так у вас нет репликации, вы что пытаетесь сделать...

по таблицам - хочу иметь таблицы на нодах 1-8 (в рамках кластера clickhouse1), и иметь для вставки distributed таблицу по партициям - хочу по запросу ```SELECT * FROM system.parts WHERE active and database = '<db>' ``` получать список всех партиций ЧЯДНТ?)

0

06.07.2021

Denny [Altinity]

Kuzma Leshakov
по таблицам - хочу иметь таблицы на нодах 1-8 (в р...

да все делаете не так

0

06.07.2021

Kuzma Leshakov Автор вопроса

Denny [Altinity]
каша, какая каша. Если вы используете инсерт в Di...

в 19 версии видимо нет system.distribution_queue, btw

0

06.07.2021

Denny [Altinity]

Kuzma Leshakov
в 19 версии видимо нет system.distribution_queue, ...

19 is out of support

0

06.07.2021

Kuzma Leshakov Автор вопроса

Denny [Altinity]
да все делаете не так

такс, создаем кластер, на них таблицы CREATE TABLE ON CLUSTER. Также создаем таблицу Distributed, которая смотрит на созданные ранее таблицы. Данные вставляем в Distributed, она уже раскидывает по нодам. Это верно? Неверно на моменте запроса партиций?

0

07.07.2021

Kuzma Leshakov Автор вопроса

Denny [Altinity]
да все делаете не так

собственно, SELECT distinct partition FROM cluster({cluster}, system, parts) проблему решил

0

07.07.2021

Denny [Altinity] · Accepted Answer

Denny [Altinity]

никак. system.parts ничего не знает про кластер.

0

06.07.2021

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

А как работает получение списка партиций `SELECT * FROM system.parts WHERE

10 ответов

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