Но вообще вроде все пользуются вторым вариантом, единственный неприятный момент есть, что в некоторых случаях при агрегации вставки в summary таблицы данные могут потерять уникальность до такой степени, что их дедуп не пропустит

Т.е. делаем две ReplicatedMT
И МВ из первой во вторую?

Ну и на каждой реплике нужно создать такую MV

МВ на каждом ноде не "кабум"нет ничего?

Т.е. дедупликая отработает и все

MV триггерится только на вставку, протокол репликации ей побоку.
Так что нужно создать MV на каждом хосте, куда потенциально может прийти вставка

Ок, спасибо. Теперь яснее. Если вставлять в одну реплику проблем не будет.

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

Получилось реализовать через runningDifferenceStartingWithFirstValue()

А каким образом?
эта функция как и neighbor живет в пределах блока, если вас все устраивает то ок

select status, runningDifferenceStartingWithFirstValue(status) as statusChange, eventTime from
(
select status, eventTime from monitor.events where  monitorId = 118 and eventTime >= '2020-06-05 23:12:00'  order by eventTime
)
group by status, statusChange, eventTime having statusChange <> 0  order by eventTime

У меня события по монитору приходят не чаще чам раз в минуту, максимум нужно считать за месяц, получается 60*24*31=44640 событий в месяц для монитора, я так понимаю, что это в пределах блока?

Вот вывод
1  1  2020-06-11 15:06:00
3  2  2020-06-11 15:10:00
1  -2  2020-06-11 16:00:00
3  2  2020-06-11 16:25:00
1  -2  2020-06-11 16:35:00

Привет) При использовании WITH FILL будут заливаться пустые строки лишь в том случае, когда есть результаты по какой-либо из дат в диапазоне, в противном случае запрос ничего не вернет. Как заставить его в любом случае возвращать пустой, но заполненный диапазон?

SELECT date,
       sum(parent_profit) as sum
FROM referral_income
WHERE date >= toDate('{start_date}') AND
      date <= toDate('{end_date}')
GROUP by date
ORDER BY date
WITH FILL FROM toDate('{start_date}') TO toDate('{end_date}')

хм, вообще возможно это можно все заменить на WHERE statusChange <> 0
64 тысячи это максимальный размер блока. строго говоря никто не запрещает ему быть меньше, но тк ты дергаешь данные из подзапроса а там сортировка оно должно работать нормально емнип.

Всем привет, вот такая штука
Poco::Exception. Code: 1000, e.code() = 2002, e.displayText() = mysqlxx::ConnectionFailed: Can't connect to MySQL server on '127.0.0.1' (115) ((nullptr):0) (version 20.4.5.36 (official build))
+- в чем может быть проблема, при создании таблицы хост указывался как 127.0.0.1

тамблица с Engine=MySQL() ?

да

ну проверяйте коннект по реквизитам,
https://clickhouse.tech/docs/en/engines/table-engines/integrations/mysql/#creating-a-table
которые в Engine=MYSQL(...) указывет
поставьте apt-get install -y mysql-client

и mysql -h 127.0.0.1 -u ....
там может быть так, что

демон  MySQL стоит на том же сервере что демон ClickHouse ?

Ребята а подскажите что я упускаю. Есть вот такие два запроса я думал что результат должен быть идентичен,  но это не так :(

1. SELECT uniqExact(uniqValue) FROM logs;
возвращает 70 500

2. SELECT sum(cnt) FROM (SELECT count(*) as cnt FROM logs GROUP BY uniqValue);
150000 записей.

в втором запросе ты сначала получаешь число повторений для каждого uniqValue а потом их все суммируешь