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

[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