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

Подскажите, пожалуйста, в чём может быть проблема при настройке кластера. Создаю

3 шарда, в каждом 2 реплики. Далее вставляю в таблицу 1000 записей. Делаю COUNT() в табице — количество записей верное — 1000. Выполняю запрос

SELECT
FQDN() AS h,
COUNT()
FROM entries
GROUP BY h

Получаю вот такой результат:

─h──────────────────────────┬─count()─┐
│ example-cluster-node-01-02 │ 329 │
│ example-cluster-node-03-01 │ 311 │
│ example-cluster-node-02-02 │ 360 │
└────────────────────────────┴─────────┘

Тоже всё верно по количеству.

Но при выполнении запроса

SELECT
FQDN() AS h,
COUNT()
FROM clusterAllReplicas('example_cluster', test, entries)
GROUP BY h

Получаю результат, в котором данные между репликами отличаются:

┌─h──────────────────────────┬─count()─┐
│ example-cluster-node-01-02 │ 1316 │
│ example-cluster-node-02-01 │ 1440 │
│ example-cluster-node-03-01 │ 933 │
│ example-cluster-node-03-02 │ 933 │
│ example-cluster-node-01-01 │ 658 │
│ example-cluster-node-02-02 │ 720 │
└────────────────────────────┴─────────┘

Причём отличаются ровно в 2 раза, и каждый раз результат разный: то у одной группы реплик разница в 2 раза, то у двух групп.
В чём проблема?

7 ответов

14 просмотров

entries distributed таблица?

Rodion-Baskakov Автор вопроса
Rodion Baskakov
Да, конечно

Надо к mergetree делать запрос через clusterAllReplicas

Rodion-Baskakov Автор вопроса
Konstantin Ilchenko
entries distributed таблица?

Создавалась вот так: CREATE TABLE IF NOT EXISTS test.entries AS test.entries_shard ENGINE = Distributed(example_cluster, test, entries_shard, murmurHash3_64(parameter));

Rodion-Baskakov Автор вопроса
Konstantin Ilchenko
Надо к mergetree делать запрос через clusterAllRep...

Так я, вроде, так и делаю в своём примере выше, где данные по репликам отличаются

Rodion-Baskakov Автор вопроса
Konstantin Ilchenko
clusterAllReplicas(example_cluster, test.entries_s...

🤦 спасибо, не то запрашивал

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

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

А чем вам питонисты не угодили?😂
.
79
Язык Си можно выучить за день? По книжке ANSI C на 230 страниц
Vincent Vegan
29
Привет, запускаю werf в dind в k8s, получаю ошибку на этапе build/beforeSetup: /.werf/stapel/embedded/bin/bash: /.werf/scripts/5898bdfe5214357d3706b879cc8d3d78460fb379607cbd...
florius0
7
Всем привет, написал код ниже, но он выдает сегфолт, в чем причина? #include <stdio.h> #include <stdlib.h> #include <string.h> struct product { char *name; float price; };...
buzz базз
75
Dim Dim, [02.07.2024 11:07] DB 0x62 Dim Dim, [02.07.2024 11:07] DB 0x66 Dim Dim, [02.07.2024 11:07] кто пояснит что это?
Dim Dim
14
Ошибка: segmentation fault (core dumped) Код: pastebin.com/BEsNNSSV Сообщение от компилятора: отсутствует ОС: Arch Linux Ядро: x86_64 Linux 6.9.7-arch1-1 Процессор: Intel Cele...
sec
4
Ребят, а за скок можно впарить анон чат с апишкой и веб админкой ?
Eugene Неелов
15
Добрый день, чат. Мне в очередь из других RabbitMQ по shovel валятся метрики в формате текста для Prometheus. Помогите пожалуйста подружить RabbitMQ и Prometheus, чтобы он (...
Aleksey
4
@ahndmn @ayaw0_0 здарова, на чем пишете?
Aiwan \ (•◡•) / _bot
7
Кстати, я тут еще с одной темой столкнулся, вот учу я C++, на таком то ресурсе, а остальные постоянно советуют практиковаться, что то писать, проекты, но как писать если вот т...
aaswq1
7
Карта сайта