У таблиц ENGINE = MergeTree()

тогда не может быть никакого лага, это невозможно в КХ
в КХ инсерт возвращает управление когда парты в списке active, селект видит все active. Может быть лаг на реплике, но обычно лаг 1-2 сек, пока реплика качает новый парт.

привет!
пробую использовать фунцию groupArrayMovingSum на distributed таблице, получаю ошибку:

Code: 63. DB::Exception: Received from localhost:9000. DB::Exception: Unknown aggregate function movingXXX: while receiving packet from clickhouse-log4.:9000.

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

подскажите, можно как то заставить фунцию работать с distributed таблицей

КХ у вас древний, без groupArrayMovingSum

Ну вот то то и оно, в кафке лаг = 0, но записи появляются с задержкой, может быть это из-за лага в приватной сети вообще? Может быть такое?

ну на локальной табличке в той же версии сервера работает

а лаг чем мониторите? консьмером? попробуйте снаружи чем-то мониторить например https://github.com/danielqsj/kafka_exporter

ну должно работать, у меня работает
select groupArrayMovingSum(dummy) from remote(replicated, system, one)
select FQDN() h, groupArrayMovingSum(number) from remote(replicated, system, numbers) where number <10 group by h

Да просто запрашивали командой в консоли, там CURRENT-OFFSET был,  LOG-END-OFFSET был и LAG = 0

Но этот экспортёр у нас тоже есть, в графане есть дашборды тоже

помоему remote() немного не так работает как engine Distributed

remote создает временную таблицу с engine Distributed

Коллеги, привет.
Подскажите, пожалуйста. Хочу узнать сколько прошло микросекунд с начала дня:
select toDateTime64('2020-05-05 20:20:12.123456', 6) - toStartOfInterval(toDateTime64('2020-05-05 20:20:12.123456', 6), INTERVAL 1 day)

Но ловлю ошибку:
DB::Exception: Illegal types DateTime64(6) and DateTime('Europe/Moscow') of arguments of function minus

Почему toStartOfInterval конвертирует из datetime64 в datetime?
DateDiff использовать не могу тут. Не умеет он работать с DateTime64.

есть toUnixTimestamp64Micro

по всей видимости не в 20.3 версии(

интересно)

спасибо, из всего этого я думаю смогу построить требуемую конструкцию))

если задать более одного remote сервера, то не работает:

SELECT groupArrayMovingSum(value)
FROM remote('cld-clickhouse-log1', system, metrics)

┌─groupArrayMovingSum(value)─────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────┐
│ [2,2,2,2,2,2,2,2,2,2,2,4,5,5,13,13,14,14,14,14,14,15,86278925,2291089624,-122688189272,-122688189272,-122688189271,-122688189269,-122688189268,-122688189264,-122688189264,-122688189264,-122688189264,-122688189264,-122688189264,-122688189264,-122688134838,-122669119835,-122669119835,-122669119835,-122669119831,-122669119831,-122669119736,-122669119693,-122669119693,-122669119693,-122669119693] │
└────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────┘

1 rows in set. Elapsed: 0.003 sec.


SELECT groupArrayMovingSum(value)
FROM remote('cld-clickhouse-log{1..4}', system, metrics)

← Progress: 0.00 rows, 0.00 B (0.00 rows/s., 0.00 B/s.) Received exception from server (version 19.15.3):
Code: 63. DB::Exception: Received from localhost:9000. DB::Exception: Unknown aggregate function movingXXX: while receiving packet from cld-clickhouse-log2:9000.

0 rows in set. Elapsed: 0.006 sec.

а покажите

SELECT version()
FROM remote('cld-clickhouse-log1', system, one)