Скажите, кто как логирует и собирает метрики при взаимодействии КХ с кафкой c engine=Kafka, и какие инструменты используете? больше всего интересуют ошибки при попытке записать данные в КХ, полученные из топиков кафки
Коллеги, нужна помощь. Сделал я мутацию на апдейт, и как я теперь уже понимаю, очень неоптимально. Теперь кликхаус пытается эту мутацию применить, и для этого съедает всю оперативку, потом своп, потом просто все ложится. Можно ли как-то удалить выполнение этой мутации (при погашенном кх, т.к. при поднятом это вообще невозможно)? Ну или можно ли как-то ограничить использование памяти, чтобы он ее все-же закончил?
Коллеги, нужна помощь. Сделал я мутацию на апдейт, и как я теперь уже понимаю, очень неоптимально. Теперь кликхаус пытается эту мутацию применить, и для этого съедает всю оперативку, потом своп, потом просто все ложится. Можно ли как-то удалить выполнение этой мутации (при погашенном кх, т.к. при поднятом это вообще невозможно)? Ну или можно ли как-то ограничить использование памяти, чтобы он ее все-же закончил?
Коллеги, нужна помощь. Сделал я мутацию на апдейт, и как я теперь уже понимаю, очень неоптимально. Теперь кликхаус пытается эту мутацию применить, и для этого съедает всю оперативку, потом своп, потом просто все ложится. Можно ли как-то удалить выполнение этой мутации (при погашенном кх, т.к. при поднятом это вообще невозможно)? Ну или можно ли как-то ограничить использование памяти, чтобы он ее все-же закончил?
Это distributed таблица, он в /var/lib/clickhouse/data/ создает папки типа user:password@shard1replica1.domain.com,user:password@shard1replica2.domain.com и я так понимаю перед тем как заливать части данных на другие шарды помещает их сюда. Так вот я убрал из списка кластера эти шарды и добавил новые, все работает, но папка осталась и когда я отключаю старые реплики, он все еще пытается к ним коннектиться. Вопрос именно о distributed таблицах, их вроде как раз нет в зоокипере.
А детач/ атач не пробовали? таблицу distributed можно пересоздать drop/create
Коллеги, нужна помощь. Сделал я мутацию на апдейт, и как я теперь уже понимаю, очень неоптимально. Теперь кликхаус пытается эту мутацию применить, и для этого съедает всю оперативку, потом своп, потом просто все ложится. Можно ли как-то удалить выполнение этой мутации (при погашенном кх, т.к. при поднятом это вообще невозможно)? Ну или можно ли как-то ограничить использование памяти, чтобы он ее все-же закончил?
можешь пробнуть, пока сервак живет, удалить мутацию из system.mutations
Привет, а какой путь для вставки выбрать? Слышал что с кафкой были проблемы, а прокси больше на какие-то поделки похожи или есть какая-то самая используемая? понятно что вопрос мейнстримовый, но не хотелось бы неверную дорожку выбрать, должен быть какой-то один самый правильный способ как правило
Привет, а какой путь для вставки выбрать? Слышал что с кафкой были проблемы, а прокси больше на какие-то поделки похожи или есть какая-то самая используемая? понятно что вопрос мейнстримовый, но не хотелось бы неверную дорожку выбрать, должен быть какой-то один самый правильный способ как правило
вы озвучьте сколько данных льете. какими порциями из какого источника серебрянной пули нет
кафка не обязательно должна через kafka engine юзаться варианты разные есть ENGINE=Buffer() , clickhouse-bulk, kittenhouse
единственное что надо в голове держать что MergreTree надо вставлять либо не чаще 1 раз в секунду , либо вставлять большими пачками по 10 тыс записей (а лучше по 100 и более тыщ)
вы озвучьте сколько данных льете. какими порциями из какого источника серебрянной пули нет
кафка не обязательно должна через kafka engine юзаться варианты разные есть ENGINE=Buffer() , clickhouse-bulk, kittenhouse
единственное что надо в голове держать что MergreTree надо вставлять либо не чаще 1 раз в секунду , либо вставлять большими пачками по 10 тыс записей (а лучше по 100 и более тыщ)
Добрый день, Прошу помощи бывалих так как знакомство только начал. Задача следующая. Есть несколько типов ивентов и таймстампом, все в одной табличе. Нужно посчиать солько всего было каких ивентов каждый день за последние х дней.