在缓存上迭代时，Ignite会消耗所有内存并导致OutOfMemory失败

Question

我试图使用ScanQuery和iterator迭代所有缓存实体（而不是立即将它们从分布式缓存拉到本地客户机）：

IgniteCache cache = ignite.getOrCreateCache("test2");
ScanQuery<Integer, Person> scan = new ScanQuery<>();
scan.setPageSize(256);
Iterator<Cache.Entry<Integer, Person>> it = cache.query(scan).iterator();
int id;
while(it.hasNext()) {
    id = it.next().getValue().getId();
    <...>
}

但是上面的代码失败了，消耗了所有可用的内存。同时，当我试图从缓存中获取迭代器时，它工作得很好：

    IgniteCache cache = ignite.getOrCreateCache("test2");
    Iterator<Cache.Entry<Integer, Person>> it = cache.iterator();
    int id;
    while(it.hasNext()) {
        id = it.next().getValue().getId();
        <...>
    }

文件声明：

QueryCursor表示查询结果集，并允许透明的逐页迭代。每当用户开始迭代上一个页面时，它将自动在后台请求下一个页面。

那么为什么用ScanQuery在缓存上迭代时ignite本地节点会失败呢？

Answer 1

它看起来像是一个已知的问题https://issues.Apache.org/jira/browse/Ignite-8892它已经被修复，并将在Apache Ignite2.7中提供。您能用最新的主分支检查您的代码吗？