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 ++. (см. Фрагмент кода ниже)
фрагмент кода (Main):


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

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

            if (jobInfo.id == -1) {
                if (!jobFound) {
                    std::this_thread::sleep_for(std::chrono::seconds(1));
                    continue;
                } else {
                    break;
                }
            }

            jobFound = true;
            jobsProcessed++;

            if (jobInfo.dataOffset > 0 || jobInfo.dataLimit > 0) {
                int trades = dbHandler.readTrades(jobInfo);
                if (trades < 0) {
                    std::cerr

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

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

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

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

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

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

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