Apache Ignite 2.17.0 - Как закрыть курсор в C ++ (тонкий клиент) [закрыто]C++

Программы на C++. Форум разработчиков
Ответить Пред. темаСлед. тема
Anonymous
 Apache Ignite 2.17.0 - Как закрыть курсор в C ++ (тонкий клиент) [закрыто]

Сообщение Anonymous »

Я работаю над приложением C ++, которое взаимодействует с Apache Ignite. Приложение получает ожидающие задания с кэша заданий и обрабатывает их в цикле. Для каждой работы мне нужно прочитать связанные данные из двух других кэша: задачи и trades . These caches contain entries linked to the job via a jobId field.
Since I don't have the keys for the tasks and trades entries, I use a query cursor to iterate through the caches and find entries matching the current jobId.
The issue:

После обработки 128 -й задания моя приложение выбрасывает ошибку, не при выборе задания , но при запросе задач или trades cache с использованием курсора. Похоже, что курсор не будет должным образом разрушен и не выпущен, что приводит к истощению ресурсов или аналогичной проблеме. < /P>
Attempting to read job from Ignite...
2025-07-09T16:59:25.023273680Z Job #128 picked by this engine: jobId=158355, groupId=6301d88b-fb0a-4139-9222-3d0d5b278268
2025-07-09T16:59:25.023297002Z Reading trades from Ignite for job id: 158355
2025-07-09T16:59:25.080752036Z Error processing job: Too many open cursors (either close other open cursors or increase the limit through ClientConnectorConfiguration.maxOpenCursorsPerConnection) [maximum=128, current=128]
< /code>
Я поместил курсор в прицел {}, поэтому, как только сфера заканчивается, курсор должен быть уничтожен. Я не уверен, как я могу уничтожить курсор в C ++. (см. Сплы ниже кода)
Окончательный вопрос: как использовать курсор в C ++ таким образом, чтобы его разрушили в конце вместо оставшегося открытого?

    DBHandler dbHandler;
    bool jobFound = false;
    int jobsProcessed = 0;

    while (true) {
        try {
            auto jobInfo = dbHandler.readJob();

            jobFound = true;
            jobsProcessed++;
            int trades = dbHandler.readTrades(jobInfo);

        } catch (const std::exception& e) {
            std::cerr

Подробнее здесь: https://stackoverflow.com/questions/796 ... hin-client
Реклама
Ответить Пред. темаСлед. тема

Быстрый ответ

Изменение регистра текста: 
Смайлики
:) :( :oops: :roll: :wink: :muza: :clever: :sorry: :angel: :read: *x)
Ещё смайлики…
   
К этому ответу прикреплено по крайней мере одно вложение.

Если вы не хотите добавлять вложения, оставьте поля пустыми.

Максимально разрешённый размер вложения: 15 МБ.

  • Похожие темы
    Ответы
    Просмотры
    Последнее сообщение

Вернуться в «C++»