для большинста случаев тебе нужно семейство MergeTree движков. Судя по пути движок стоит не MergeTree. Чтобы посмотреть движок "show create table", в конце он написан
Спасибо! CREATE TABLE myapp.appmetrica_app ( user_id UInt32, token String, id UInt32, name String) ENGINE = Log │ А как поменять?
mapper делал вставку в удаленный clickhouse через jdbc, batch insert'ами. Батчи были примерно по 100к записей. Один батч - одна map таска. Со "сколько их запускается одновременно" - проблема. Я не нашел способа ограничить количество одновременно работающих map тасок на уровне одной джобы. Только целиком для кластера. А это мешало бы другим джобам.
mapper делал вставку в удаленный clickhouse через jdbc, batch insert'ами. Батчи были примерно по 100к записей. Один батч - одна map таска. Со "сколько их запускается одновременно" - проблема. Я не нашел способа ограничить количество одновременно работающих map тасок на уровне одной джобы. Только целиком для кластера. А это мешало бы другим джобам.
у нас похожая проблема была переливки тб данных с продового хадупа на Вертику. выкрутились ресурсным пулом, который ограничивал количество конкурентов юзеру, с которого ходил хадуп по JDBC. у КХ можно как то на юзера аналогично ресурсному пулу Вертики прописать количество конкурентов и время в очереди ожидания сессий пула?
У нас есть такое только для общего количества запросов на сервер. Но почти бесполезно. Потому что выполняющийся запрос не обязательно тратит ресурсы, а может ждать данных по сети или отправлять данные клиенту. Поэтому общее количество запросов на сервер ставим в заведомо большую величину.
А вот для пользователей было бы полезно. Например, ставишь максимум два одновременных запроса, третий ждёт.
в вертике поглубже сделано - там есть понятие "пул ресурсов", на который цепляется выделенная память, приоритеты на доступ к ресурсам, можно прицепить явно количество процов и количество конкурентов. на пулы тематических пользователей цепляют, например пул для загрузчиков, для агрегатников, для адхоков, для систем забора инфы и т.д.