Тайм-аут совокупного запроса Кассандры
Я новичок в Cassandra и запускаю определенную пользователем систему Aggregate в 3-узловом кластере Cassandra на локальной машине. Проблема заключается в том, что когда я запускаю этот агрегат на меньшем наборе данных, результат в порядке и, как и ожидалось.
Но когда данные слишком велики, запрос завершается с ошибкой -
OperationTimedOut: errors = {'127.0.0.1': 'Тайм-аут запроса клиента. См. Session.exe cute_async'}, last_host=127.0.0.1
Я нашел ниже вопросы, похожие на мою проблему, но они не получили ответа. Найти ссылку на Другие вопросы -
Cassandra CQLSH OperationTimedOut error= Тайм-аут запроса клиента. См. Session.execute[_async](время ожидания)
Я изменил cassandra.yaml и ограничения по времени -
read_request_timeout_in_ms: 555000
range_request_timeout_in_ms: 10000
write_request_timeout_in_ms: 2000
counter_write_request_timeout_in_ms: 5000
cas_contention_timeout_in_ms: 1000
truncate_request_timeout_in_ms: 60000
request_timeout_in_ms: 10000
Но это не помогло мне. Пожалуйста, укажите, какова правильная конфигурация для этих таймингов, чтобы выполнить тот же запрос для большого набора данных без тайм-аута запроса.
Совокупный код -
CREATE FUNCTION countSessions(datamap map<text,int>,host text)
RETURNS NULL ON NULL INPUT
RETURNS map<text, int>
LANGUAGE java as
'
Integer countValue = (Integer)datamap.get(host);
if(countValue == null) {
countValue = 1;
} else {
countValue++;
} datamap.put(host,countValue);
return datamap;
';
CREATE OR REPLACE AGGREGATE hostaggregate(text)
SFUNC countSessions
STYPE map<text, int>
INITCOND {};
Спасибо и всего наилучшего,
Vibhav
PS - Если кто-то решит отказаться от голосования по этому вопросу, пожалуйста, укажите причину этого в комментариях.