как бы runningAccumulate это такая очень странная хрень очень ограниченного применения, пока непонятно что вам надо можно только гадать.

SELECT
    d,
    n
FROM
(
    SELECT
        groupArray(date) AS dg,
        arrayCumSum(groupArray(n)) AS ng
    FROM
    (
        SELECT
            arrayJoin(['2020-01-01', '2020-01-02', '2020-01-03']) AS date,
            1 AS n
        ORDER BY date ASC
    )
)
ARRAY JOIN
    dg AS d,
    ng AS n

┌─d──────────┬─n─┐
│ 2020-01-01 │ 1 │
│ 2020-01-02 │ 2 │
│ 2020-01-03 │ 3 │
└────────────┴───┘

@den_crane У меня есть список событий, по каждому событию есть timestamp и некое значение. В зависимости от типа значения оно будет либо прибавляться, либо отниматься (но этим можно пренебречь - пусть всегда прибавляется). Мне нужно найти кумулятивное значение на конец каждого дня

кумулятивное значение на конец каждого дня === sum
не нужен нарастающий итог

Нужен, если бы не нужен, то все просто.

т.е. day (N + 1) = day N + (all values in day (N + 1))

я читаю то что вы пишете и у себя в голове отражаю ваши слова. Поэтому я и говорю что непонятно что вам нужно

ну это sum как это не смешно звучит

т.е. непонятно надо за прыдущие дни строки показать или надо одну финальную сумму7

А, понял. Надо строки за все дни

берите вот этот пример arrayCumSum https://t.me/clickhouse_ru/162540

Мы проверяли, что спарк с bigquery массивы корректно читал. Но перегонять в clickhouse не стали. Поэтому не знаю будут ли проблемы.

Всем привет.

Кластер из двух шардов, реплика
A-B C-D

Проверяем систему восстановления из бекапа, вернули во времени ноду B на несколько часов назад. Теперь она отказывается стартовать т.к.
DB::Exception: The local set of parts of table ДБНЕЙМ.ТейблНейм doesn't look like the set of parts in ZooKeeper: 5.22 million rows of 9.76 million total rows in filesystem are suspicious

ZooKeeper и другие ноды не откатывались

Правильной ли идеей кажется поднять на ноде B флаг force_restore_data и что именно произойдет: нода В пойдет перекачивать все с нуля с ноды А или или постарается нагнать только недостающее?

Заранее спасибо

идея про флаг правильная, скачиваться будет недостающее

Не чтение, а запись. Т.е. из монги я спарком читал массив - ок. А при попытке писать строку с колонкой с типом Array - падало

последние записи были 3 часа назад, как будто мутация делалась, а потом повисла. KILL MUTATION в мою версию похоже ещё не завезли. есть какие-то варианты определить что происходит вообще внутри?

parts_to_do не меняется вообще?

вот так висит уже 3 часа или даже больше

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

старый вопрос у меня так и не решился... жду рацпредложений от гуру )
—-
всем добрый вечер, очередная головоломка )
как за-семи-джойнить две таблицы  (а точнее отфильтровать одну при помощи второй) по совпадению в префиксе.
пока смог только так, но по итогу выпадает с аут оф мемори (видимо arrayExists  копирует входной массив на каждую строку в where).

пример

with (
  select groupArray(objfilter) from (
    select 'lvl1=2,lvl2=3,lvl3=5' as objfilter UNION ALL
    select 'lvl1=1,lvl2=3,lvl3=5,lvl4=43' as objfilter 
  )
) as fltArr
select fltArr, * from
(
select 'lvl1=2,lvl2=3,lvl3=5' as objpath UNION ALL
select 'lvl1=2,lvl2=3,lvl3=5,lvl4=2' as objpath UNION ALL
select 'lvl1=2,lvl2=3,lvl3=5,lvl4=44' as objpath UNION ALL
select 'lvl1=3,lvl2=3,lvl3=6' as objpath UNION ALL
select 'lvl1=2,lvl2=3' as objpath UNION ALL
select 'lvl1=1,lvl2=3,lvl3=5' as objpath  
) t
WHERE arrayExists(
                selectedObj ->
                     (startsWith(objpath, selectedObj)
                        or startsWith(selectedObj, objpath)),
                fltArr);

т.е. данные еще не удалились? проверяли селектом?

что возвращает вот этот запрос

select * from system.parts where bytes_on_disk > (select toInt64(value) from system.merge_tree_settings where name = 'max_bytes_to_merge_at_max_space_in_pool')