select * from system.tables;

и это сломалось )

select * from system.tables;

надеюсь хоть база не продуктовая?(

конечно продуктовая. вот обновляю CV параллельно =)

ну тогда напоследок можно rm -r /var/lib/clickhouse )

Дратути, коллеги!

Вопрос такой: хочу развернуть Click House на GoogleCloud. VM на ubuntu 16.04. Задача: складывать данные в Click House через R и потом подключаться к Click House при помощи Power BI. Какие могут быть проблемы? Кто-то может подсказать?

Здравствуйте,

Запрос:
SELECT
   year,
   month,
   day,
   COUNT() * any(_sample_factor) AS data
FROM events
SAMPLE 10000
WHERE (event_time > 1594109197) AND (project_id = 171) AND (year IN (20)) AND (month IN (7, 8)) AND (event_name = 'view')
GROUP BY
   year,
   month,
   day

Получаю ошибку:
Code: 49. DB::Exception: Received from localhost:9000. DB::Exception: RangeReader read 13084 rows, but 13198 expected.

В чем может быть ошибка?

ClickHouse server version 20.1.4.14

Вопрос про комбинаторы агрегатной функции -State, возможно есть функция или подход к решению? Необходимо найти пересечение (intersection) двух групп пользователей разных сайтов. В документации есть рабочий пример через использование IN, что типа SELECT uniq(UserID) FROM distributed_table WHERE CounterID = 101500 AND UserID IN (SELECT UserID FROM local_table WHERE CounterID = 34)

Допустим у меня уже есть “свертки” по уникам, по дням. Уники уже хранятся в виде результата выполнения комбинатора агрегатной функции uniqCombinedState. Можно ли как-то найти пересечение двух uniqCombinedState?

Ребят, привет! Какое-то время назад писал об этой проблеме, но так и не поборол её.
Начала сыпать ошибка WriteBufferFromHTTPServerResponse полный лог ошибки ниже.
Причину не пойму. Куда можно копать, может кто-то сталкивался с таким?

Привет! После рестарта кликхауса на /replicas_status был absolute delay в неделю почти. Почему неделя, а не пара минут максимум? Как это значение высчитывается?

Гуру, подскажите пожалуйста по проблеме,
есть кластер (v20.4.4, 2 шарда по 2 реплики), 3 ноды из 4х постоянно спамят ошибки по несколько раз в секунду:

<Error> executeQuery: Code: 252, e.displayText() = DB::Exception: Too many partitions for single INSERT block (more than 100).

одна из нод (реплика ноды с которой все ок) спамит дополнительно :

<Error> default.snapshot.DirectoryMonitor: Code: 252, e.displayText() = DB::Exception: Received from xxxx:9000. DB::Exception: Too many partitions for single INSERT block (more than 100)

Причем спамит и в такое время, в которое в КХ никто не пишет. Такое ощущение что репликация какая-то залипла.. но replication_queue пустая на всех нодах. Куда еще можно посмотреть?

<Error> executeQuery: Code: 252, e.displayText() = DB::Exception: Too many partitions for single INSERT block (more than 100).

<Error> default.snapshot.DirectoryMonitor: Code: 252, e.displayText() = DB::Exception: Received from xxxx:9000. DB::Exception: Too many partitions for single INSERT block (more than 100)

Репликация не через инсерты работает

У меня есть таблица на engine=kafka. Дальше я построил материализованную вьюху на таблицу data. Вопрос в том, как мне сообщить kafka что запись записалась в таблицу data ?

Здравствйте! Вопрос такой - как соотносится, примерно, объем данных, который в клик пишем, и то, что там хранится в итоге на диске?

Зачем Вам сообщать Кафке о том что была запись?

чтобы быть уверенным, что я не потерял запись

Впервые о таком методе слышу, но с большой вероятностью никак Вы не сообщите Кафке, что запись была осуществлена

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

Если Вы понимаете как работает Кафка, то наверное знаете, что есть некий период, который она хранит сообщения после прочтения. Этим можно воспользоваться в случае если данные не записались, то прочитать их ещё раз для этого Вам конечно же нужно знать смещение

спасибо