Тайм-аут совокупного запроса Кассандры

Я новичок в 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 - Если кто-то решит отказаться от голосования по этому вопросу, пожалуйста, укажите причину этого в комментариях.

0 ответов

Другие вопросы по тегам