A P

А были ли у кого-то проблемы со сборкой? Собираю на centos7,  при помощи devtoolset-9 и ninja, получаю такое [10/302] Building CXX object src/Functions/GatherUtils/CMakeFiles/...

Ребят, есть кто гоняет джаву в докере и кубере? Я выставляю лимиты на контейнер (2 гига), но не выставляю лимиты на джаву при запуске. В итоге, когда захожу в исполняющийся ко...

Подскажите, а ведь партиции внутри кх нарезаются на part’ы, да? В чем состоит мотивация резать колонку на part’ы? Чтобы файл в вызов mmap пролезал?Или что?

Всем привет. У меня есть таблица на 63 колонки, но данные, которыми наполняется эта таблица, достаточно разреженные (в одной записи может быть 20-30 полей) Сейчас мы инсертим...

Тут недавно спрашивали про liveness, у меня тоже вопросик есть У меня в деве периодически отваливается соединение с кафкой, получаю такую ошибку This member will leave the gro...

Ребят, а как можно красиво перейти от обычного итератора к реверсированного по флагу? if (order) { auto beg = current.rbegin(); auto end = curr...

Добрый день У меня есть объект, который необходим для создания новой колонки в pyspark'е, но он не pick'лится Как я могу обойти это ограничение и получить нужную мне колонку?

Пользуясь случаем, задам ещё вопрос: При попытке поскейлить приложение kubectl scale --replicas=1 deployment <depname> Получаю Error from server (Forbidden): deployments.exte...

Всем привет, а есть ли решение для хранения результатов запросов в кликхауз за большой временной промежуток? Сейчас используется такая схема: по крону раз в час исполняются за...

А кто пользовался ksqlDB? У меня есть задача - считать стату по топику в режиме реального времени двадцатиминутками Нагрузка в топике 15-20к рпс Я сижу, думаю, как получше это...

Подскажите пожалуйста, у меня есть таблица с колонками user_id (String) и user_id_tmp (int64) Если я сделаю что-то вроде alter table pulse.kafka2ch_replicated on cluster tabl...

Ребят, что делать, если у меня в system.replication_queue висит упавший запрос? Я пытался сконвертить столбец типа String в Int64, где-то затесался мусор и запрос упал, но в r...

Привет, у меня ещё вопросик по kafka-streams Я при определении топологии создаю объект партишенера: textLines.to(OUT_TOPIC, Produced.streamPartitioner(partitioner)); Я могу бы...

А имеется ли возможность сделать синхронный alter table? Мне надо дропнуть партицию и заново налить её, хочу убедиться, что новые данные не попадут под действие drop partition

подскажите пожалуйста, кто пользуется kafka-streams.Если я запущу приложение на kafka-streams на нескольких машинах с одинаковым application_id, эти приложения будут работать ...

Вкратце:У меня есть *.cpp файлик,который зависит от .hpp хедера,лежащего в другой директории.Как их подружить с clang-ом?

А такое ловил кто-нибудь?(вопрос к кафкаводам) org.apache.kafka.common.errors.TimeoutException: Topic not present in metadata after 60000 ms

Коллеги, а нет ли случаем функции для получения топ K значений по ключу, как topKWeighted, только для вещественного ключа? А то приходится велосипеды писать

Скажите, а какие есть best practice при работе с кх и кафкой?(если в кафке сырые логи с nginx’ов) Через kafka-streams писать логи в новый топик в виде, пригодном для чтения кл...

скажите, а если я на одном stateless объекте из разных потоков вызываю один и тот же метод с разными параметрами, возможны ли рейсы?