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

Всем привет! Столкнулся с такой проблемой: на одной ноде нет

данных и читая из Distributed таблицы получаю пустое множество. В db_name.bid_agg_ifa_local на этой ноде тоже пусто. У нас есть кластер, по кластеру размазана основная таблица. Все новые данные, попадающие в эту таблицу через матвью переливаются в другую таблицу AggregatingMergeTree, код ее созданию приведен ниже create table db_name.bid_agg_ifa_local on cluster '{cluster}'
(
ts DateTime,
event_date date,
device_id String,
geo_hash_2 String,
geo_hash_3 String,
geo_hash_4 String,
geo_hash_5 String,
geo_hash_6 String,
geo_hash_7 String,
geo_hash_8 String,
geo_hash_9 String,
cnt AggregateFunction(sum, UInt32),
INDEX uuid_bloom device_id TYPE bloom_filter(0.01) GRANULARITY 1
)
engine = AggregatingMergeTree()
PARTITION BY toYYYYMMDD(event_date)
order by (geo_hash_2, geo_hash_3, geo_hash_4, ts, geo_hash_5, geo_hash_6, geo_hash_7, geo_hash_8, geo_hash_9)
primary key (geo_hash_2, geo_hash_3, geo_hash_4, ts, geo_hash_5, geo_hash_6, geo_hash_7, geo_hash_8, geo_hash_9)
;

CREATE TABLE db_name.bid_agg_ifa on cluster '{cluster}' AS db_name.bid_agg_ifa_local
ENGINE = Distributed('{cluster}', db_name, bid_agg_ifa_local, sipHash64(device_id)); В чем модет быть причина? Подскажите, пожалуйста

4 ответов

6 просмотров

AggregatingMergeTree() я бы ожидал увидеть ReplicatedAggregatingMergeTree() это осознаннно? основная таблица Replicated? или нет?

Igor-Gorbenko Автор вопроса
Denny [Altinity]
AggregatingMergeTree() я бы ожидал увидеть Replica...

все именно так, основная таблица ReplicatedMergeTree, а эта была создана как AggregatingMergeTree.Спасибо за подсказку!

Igor-Gorbenko Автор вопроса
Denny [Altinity]
AggregatingMergeTree() я бы ожидал увидеть Replica...

Приветствую! Все получилось как подсказали, но почему то в агрегационной таблицы не бьются данные с исходной таблицей db_name.bid_agg_ifa. Общая сумма по полю агрегации (cnt) сходится, но, например, не хватает некоторых device_id да и вообще если проверять по каждому конкретному device_id между двумя таблицами - всегда есть расхождения. Если бы общая сумма не билась, я бы грешил на задержку во поставке данных в агрегационную таблицу. Где копать?

Igor Gorbenko
Приветствую! Все получилось как подсказали, но поч...

device_id не в order by у ReplicatedAggregatingMergeTree т.е. вам надо понять matview вообще вообще никак совсем не связано с ReplicatedAggregatingMergeTree

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

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

@MrMiscipitlick А можешь макрос написать, который будет вычислять смещение относительно переданных меток? Просто .label1-.label2, и вернуть значение.
КТ315
35
я не магистр хаскеля, но разве не может лейзи тип конвертнуться в не-лейзи запросив вычисление содержимого прям при инициализации?
deadgnom32 λ madao
100
А еще в перле можно уже @arr1 + @arr2?
Sergei Zhmylove
53
Заметил в ghci 9.4.8: > :t (<*>) @((->)_) (<*>) @((->)_) :: (w -> (a -> b)) -> (w -> a) -> w -> b Разве не должно (w -> (a -> b)) быть записано как (w -> a -> b)? Это баг, ил...
Михаил
13
Привет всем. появился вопрос. Разрабатываю сайт, в данный момент он запущен. Хостинг beget. Добавляю на сайт яндекс метрику с помощью полей client-settings (взято отсюда http...
Andrew
2
Подобного рода ;Следующие три строки это директивы ассемблера, ;которые можно не задавать, т.к.работаем в Visual Studio. ;Символ ";" - это начало однострочного комментария ...
Егор Анелькин
3
Any electron dev here?
Sayanth Tezro
12
Подскажите, где смотреть результат выполнения программы? Код: ;.686 ;Система команд процессора 686 ;.MODEL FLAT,stdcall ;Модель памяти плоская, станда...
Егор Анелькин
5
так это может кто что знает или использует что-то как макбук только не макбук? на 13…14 дюймов
Michael
9
;.686 ;Система команд процессора 686 ;.MODEL FLAT,stdcall ;Модель памяти плоская, стандартный ;вызов процедуры ;option casemap:no...
Егор Анелькин
1
Карта сайта